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