@@ -136,26 +136,18 @@ async def create_yws_provider(
136
136
websocket_provider_connect = "real_websocket" ,
137
137
ydoc = None ,
138
138
):
139
- print ("create_yws_provider" )
140
139
ydoc = Doc () if ydoc is None else ydoc
141
140
if websocket_provider_connect == "real_websocket" :
142
141
server_websocket = None
143
142
connect = aconnect_ws (f"http://localhost:{ port } /{ room_name } " )
144
143
else :
145
144
server_websocket , connect = connected_websockets ()
146
- try :
147
- async with connect as websocket :
148
- websocket_provider = Provider (ydoc , Websocket (websocket , room_name ))
149
- if websocket_provider_api == "websocket_provider_start_stop" :
150
- websocket_provider = StartStopContextManager (websocket_provider )
151
- async with websocket_provider as websocket_provider :
152
- yield ydoc , server_websocket
153
- print ("done0" )
154
- print ("done1" )
155
- print ("done2" )
156
- except BaseException as e :
157
- print (f"create_yws_provider { e = } " )
158
- print ("done3" )
145
+ async with connect as websocket :
146
+ websocket_provider = Provider (ydoc , Websocket (websocket , room_name ))
147
+ if websocket_provider_api == "websocket_provider_start_stop" :
148
+ websocket_provider = StartStopContextManager (websocket_provider )
149
+ async with websocket_provider as websocket_provider :
150
+ yield ydoc , server_websocket
159
151
160
152
161
153
@asynccontextmanager
0 commit comments