Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 163723f

Browse files
leszekhanuszleszekhanusz
authoredFeb 18, 2025··
Chore bump websockets to 13.x (#532)
1 parent 0e678b9 commit 163723f

17 files changed

+82
-80
lines changed
 

‎setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@
5252
]
5353

5454
install_websockets_requires = [
55-
"websockets>=10,<12",
55+
"websockets>=10.1,<14",
5656
]
5757

5858
install_botocore_requires = [

‎tests/conftest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -501,7 +501,7 @@ def get_server_handler(request):
501501
else:
502502
answers = request.param
503503

504-
async def default_server_handler(ws, path):
504+
async def default_server_handler(ws):
505505

506506
try:
507507
await WebSocketServerHelper.send_connection_ack(ws)

‎tests/test_aiohttp_websocket_exceptions.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ async def test_aiohttp_websocket_invalid_query(
7070
"""
7171

7272

73-
async def server_invalid_subscription(ws, path):
73+
async def server_invalid_subscription(ws):
7474
await WebSocketServerHelper.send_connection_ack(ws)
7575
await ws.recv()
7676
await ws.send(invalid_query1_server_answer.format(query_id=1))
@@ -108,7 +108,7 @@ async def test_aiohttp_websocket_invalid_subscription(
108108
)
109109

110110

111-
async def server_no_ack(ws, path):
111+
async def server_no_ack(ws):
112112
await ws.wait_closed()
113113

114114

@@ -129,7 +129,7 @@ async def test_aiohttp_websocket_server_does_not_send_ack(
129129
pass
130130

131131

132-
async def server_connection_error(ws, path):
132+
async def server_connection_error(ws):
133133
await WebSocketServerHelper.send_connection_ack(ws)
134134
result = await ws.recv()
135135
print(f"Server received: {result}")
@@ -158,7 +158,7 @@ async def test_aiohttp_websocket_sending_invalid_data(
158158
)
159159

160160

161-
async def server_invalid_payload(ws, path):
161+
async def server_invalid_payload(ws):
162162
await WebSocketServerHelper.send_connection_ack(ws)
163163
result = await ws.recv()
164164
print(f"Server received: {result}")
@@ -253,7 +253,7 @@ async def test_aiohttp_websocket_transport_protocol_errors(
253253
await session.execute(query)
254254

255255

256-
async def server_without_ack(ws, path):
256+
async def server_without_ack(ws):
257257
# Sending something else than an ack
258258
await WebSocketServerHelper.send_complete(ws, 1)
259259
await ws.wait_closed()
@@ -274,7 +274,7 @@ async def test_aiohttp_websocket_server_does_not_ack(event_loop, server):
274274
pass
275275

276276

277-
async def server_closing_directly(ws, path):
277+
async def server_closing_directly(ws):
278278
await ws.close()
279279

280280

@@ -294,7 +294,7 @@ async def test_aiohttp_websocket_server_closing_directly(event_loop, server):
294294
pass
295295

296296

297-
async def server_closing_after_ack(ws, path):
297+
async def server_closing_after_ack(ws):
298298
await WebSocketServerHelper.send_connection_ack(ws)
299299
await ws.close()
300300

@@ -313,7 +313,7 @@ async def test_aiohttp_websocket_server_closing_after_ack(
313313
await session.execute(query)
314314

315315

316-
async def server_sending_invalid_query_errors(ws, path):
316+
async def server_sending_invalid_query_errors(ws):
317317
await WebSocketServerHelper.send_connection_ack(ws)
318318
invalid_error = (
319319
'{"type":"error","id":"404","payload":'

‎tests/test_aiohttp_websocket_graphqlws_exceptions.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ async def test_aiohttp_websocket_graphqlws_invalid_query(
6868
"""
6969

7070

71-
async def server_invalid_subscription(ws, path):
71+
async def server_invalid_subscription(ws):
7272
await WebSocketServerHelper.send_connection_ack(ws)
7373
await ws.recv()
7474
await ws.send(invalid_query1_server_answer.format(query_id=1))
@@ -102,7 +102,7 @@ async def test_aiohttp_websocket_graphqlws_invalid_subscription(
102102
assert error["extensions"]["code"] == "INTERNAL_SERVER_ERROR"
103103

104104

105-
async def server_no_ack(ws, path):
105+
async def server_no_ack(ws):
106106
await ws.wait_closed()
107107

108108

@@ -130,7 +130,7 @@ async def test_aiohttp_websocket_graphqlws_server_does_not_send_ack(
130130
)
131131

132132

133-
async def server_invalid_query(ws, path):
133+
async def server_invalid_query(ws):
134134
await WebSocketServerHelper.send_connection_ack(ws)
135135
result = await ws.recv()
136136
print(f"Server received: {result}")
@@ -207,7 +207,7 @@ async def test_aiohttp_websocket_graphqlws_transport_protocol_errors(
207207
await session.execute(query)
208208

209209

210-
async def server_without_ack(ws, path):
210+
async def server_without_ack(ws):
211211
# Sending something else than an ack
212212
await WebSocketServerHelper.send_complete(ws, 1)
213213
await ws.wait_closed()
@@ -230,7 +230,7 @@ async def test_aiohttp_websocket_graphqlws_server_does_not_ack(
230230
pass
231231

232232

233-
async def server_closing_directly(ws, path):
233+
async def server_closing_directly(ws):
234234
await ws.close()
235235

236236

@@ -252,7 +252,7 @@ async def test_aiohttp_websocket_graphqlws_server_closing_directly(
252252
pass
253253

254254

255-
async def server_closing_after_ack(ws, path):
255+
async def server_closing_after_ack(ws):
256256
await WebSocketServerHelper.send_connection_ack(ws)
257257
await ws.close()
258258

‎tests/test_aiohttp_websocket_graphqlws_subscription.py

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
def server_countdown_factory(
3131
keepalive=False, answer_pings=True, simulate_disconnect=False
3232
):
33-
async def server_countdown_template(ws, path):
33+
async def server_countdown_template(ws):
3434
import websockets
3535

3636
logged_messages.clear()
@@ -192,28 +192,28 @@ async def receiving_coro():
192192
return server_countdown_template
193193

194194

195-
async def server_countdown(ws, path):
195+
async def server_countdown(ws):
196196

197197
server = server_countdown_factory()
198-
await server(ws, path)
198+
await server(ws)
199199

200200

201-
async def server_countdown_keepalive(ws, path):
201+
async def server_countdown_keepalive(ws):
202202

203203
server = server_countdown_factory(keepalive=True)
204-
await server(ws, path)
204+
await server(ws)
205205

206206

207-
async def server_countdown_dont_answer_pings(ws, path):
207+
async def server_countdown_dont_answer_pings(ws):
208208

209209
server = server_countdown_factory(answer_pings=False)
210-
await server(ws, path)
210+
await server(ws)
211211

212212

213-
async def server_countdown_disconnect(ws, path):
213+
async def server_countdown_disconnect(ws):
214214

215215
server = server_countdown_factory(simulate_disconnect=True)
216-
await server(ws, path)
216+
await server(ws)
217217

218218

219219
countdown_subscription_str = """
@@ -353,7 +353,7 @@ async def close_transport_task_coro():
353353
assert count > 0
354354

355355

356-
async def server_countdown_close_connection_in_middle(ws, path):
356+
async def server_countdown_close_connection_in_middle(ws):
357357
await WebSocketServerHelper.send_connection_ack(ws)
358358

359359
result = await ws.recv()

‎tests/test_aiohttp_websocket_query.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,7 @@ async def test_aiohttp_websocket_two_queries_in_series(
228228
assert result1 == result2
229229

230230

231-
async def server1_two_queries_in_parallel(ws, path):
231+
async def server1_two_queries_in_parallel(ws):
232232
await WebSocketServerHelper.send_connection_ack(ws)
233233
result = await ws.recv()
234234
print(f"Server received: {result}", file=sys.stderr)
@@ -276,7 +276,7 @@ async def task2_coro():
276276
assert result1 == result2
277277

278278

279-
async def server_closing_while_we_are_doing_something_else(ws, path):
279+
async def server_closing_while_we_are_doing_something_else(ws):
280280
await WebSocketServerHelper.send_connection_ack(ws)
281281
result = await ws.recv()
282282
print(f"Server received: {result}", file=sys.stderr)
@@ -434,7 +434,7 @@ async def test_aiohttp_websocket_trying_to_connect_to_already_connected_transpor
434434
pass
435435

436436

437-
async def server_with_authentication_in_connection_init_payload(ws, path):
437+
async def server_with_authentication_in_connection_init_payload(ws):
438438
# Wait the connection_init message
439439
init_message_str = await ws.recv()
440440
init_message = json.loads(init_message_str)
@@ -593,7 +593,7 @@ async def test_aiohttp_websocket_add_extra_parameters_to_connect(
593593
await session.execute(query)
594594

595595

596-
async def server_sending_keep_alive_before_connection_ack(ws, path):
596+
async def server_sending_keep_alive_before_connection_ack(ws):
597597
await WebSocketServerHelper.send_keepalive(ws)
598598
await WebSocketServerHelper.send_keepalive(ws)
599599
await WebSocketServerHelper.send_keepalive(ws)

‎tests/test_aiohttp_websocket_subscription.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
}
3131

3232

33-
async def server_starwars(ws, path):
33+
async def server_starwars(ws):
3434
import websockets
3535

3636
await WebSocketServerHelper.send_connection_ack(ws)
@@ -91,7 +91,7 @@ async def server_starwars(ws, path):
9191
logged_messages: List[str] = []
9292

9393

94-
async def server_countdown(ws, path):
94+
async def server_countdown(ws):
9595
import websockets
9696

9797
logged_messages.clear()
@@ -343,7 +343,7 @@ async def close_transport_task_coro():
343343
assert count > 0
344344

345345

346-
async def server_countdown_close_connection_in_middle(ws, path):
346+
async def server_countdown_close_connection_in_middle(ws):
347347
await WebSocketServerHelper.send_connection_ack(ws)
348348

349349
result = await ws.recv()

‎tests/test_appsync_websockets.py

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ def verify_headers(headers, in_query=False):
107107
"errorCode": 400,
108108
}
109109

110-
async def realtime_appsync_server_template(ws, path):
110+
async def realtime_appsync_server_template(ws):
111111
import websockets
112112

113113
logged_messages.clear()
@@ -139,6 +139,8 @@ async def realtime_appsync_server_template(ws, path):
139139
)
140140
return
141141

142+
path = ws.path
143+
142144
print(f"path = {path}")
143145

144146
path_base, parameters_str = path.split("?")
@@ -348,28 +350,28 @@ async def receiving_coro():
348350
return realtime_appsync_server_template
349351

350352

351-
async def realtime_appsync_server(ws, path):
353+
async def realtime_appsync_server(ws):
352354

353355
server = realtime_appsync_server_factory()
354-
await server(ws, path)
356+
await server(ws)
355357

356358

357-
async def realtime_appsync_server_keepalive(ws, path):
359+
async def realtime_appsync_server_keepalive(ws):
358360

359361
server = realtime_appsync_server_factory(keepalive=True)
360-
await server(ws, path)
362+
await server(ws)
361363

362364

363-
async def realtime_appsync_server_not_json_answer(ws, path):
365+
async def realtime_appsync_server_not_json_answer(ws):
364366

365367
server = realtime_appsync_server_factory(not_json_answer=True)
366-
await server(ws, path)
368+
await server(ws)
367369

368370

369-
async def realtime_appsync_server_error_without_id(ws, path):
371+
async def realtime_appsync_server_error_without_id(ws):
370372

371373
server = realtime_appsync_server_factory(error_without_id=True)
372-
await server(ws, path)
374+
await server(ws)
373375

374376

375377
on_create_message_subscription_str = """

‎tests/test_async_client_validation.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
}
2323

2424

25-
async def server_starwars(ws, path):
25+
async def server_starwars(ws):
2626
import websockets
2727

2828
await WebSocketServerHelper.send_connection_ack(ws)

‎tests/test_graphqlws_exceptions.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ async def test_graphqlws_invalid_query(
6868
"""
6969

7070

71-
async def server_invalid_subscription(ws, path):
71+
async def server_invalid_subscription(ws):
7272
await WebSocketServerHelper.send_connection_ack(ws)
7373
await ws.recv()
7474
await ws.send(invalid_query1_server_answer.format(query_id=1))
@@ -102,7 +102,7 @@ async def test_graphqlws_invalid_subscription(
102102
assert error["extensions"]["code"] == "INTERNAL_SERVER_ERROR"
103103

104104

105-
async def server_no_ack(ws, path):
105+
async def server_no_ack(ws):
106106
await ws.wait_closed()
107107

108108

@@ -130,7 +130,7 @@ async def test_graphqlws_server_does_not_send_ack(
130130
)
131131

132132

133-
async def server_invalid_query(ws, path):
133+
async def server_invalid_query(ws):
134134
await WebSocketServerHelper.send_connection_ack(ws)
135135
result = await ws.recv()
136136
print(f"Server received: {result}")
@@ -205,7 +205,7 @@ async def test_graphqlws_transport_protocol_errors(
205205
await session.execute(query)
206206

207207

208-
async def server_without_ack(ws, path):
208+
async def server_without_ack(ws):
209209
# Sending something else than an ack
210210
await WebSocketServerHelper.send_complete(ws, 1)
211211
await ws.wait_closed()
@@ -226,7 +226,7 @@ async def test_graphqlws_server_does_not_ack(event_loop, graphqlws_server):
226226
pass
227227

228228

229-
async def server_closing_directly(ws, path):
229+
async def server_closing_directly(ws):
230230
await ws.close()
231231

232232

@@ -246,7 +246,7 @@ async def test_graphqlws_server_closing_directly(event_loop, graphqlws_server):
246246
pass
247247

248248

249-
async def server_closing_after_ack(ws, path):
249+
async def server_closing_after_ack(ws):
250250
await WebSocketServerHelper.send_connection_ack(ws)
251251
await ws.close()
252252

‎tests/test_graphqlws_subscription.py

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
def server_countdown_factory(
3131
keepalive=False, answer_pings=True, simulate_disconnect=False
3232
):
33-
async def server_countdown_template(ws, path):
33+
async def server_countdown_template(ws):
3434
import websockets
3535

3636
logged_messages.clear()
@@ -192,28 +192,28 @@ async def receiving_coro():
192192
return server_countdown_template
193193

194194

195-
async def server_countdown(ws, path):
195+
async def server_countdown(ws):
196196

197197
server = server_countdown_factory()
198-
await server(ws, path)
198+
await server(ws)
199199

200200

201-
async def server_countdown_keepalive(ws, path):
201+
async def server_countdown_keepalive(ws):
202202

203203
server = server_countdown_factory(keepalive=True)
204-
await server(ws, path)
204+
await server(ws)
205205

206206

207-
async def server_countdown_dont_answer_pings(ws, path):
207+
async def server_countdown_dont_answer_pings(ws):
208208

209209
server = server_countdown_factory(answer_pings=False)
210-
await server(ws, path)
210+
await server(ws)
211211

212212

213-
async def server_countdown_disconnect(ws, path):
213+
async def server_countdown_disconnect(ws):
214214

215215
server = server_countdown_factory(simulate_disconnect=True)
216-
await server(ws, path)
216+
await server(ws)
217217

218218

219219
countdown_subscription_str = """
@@ -353,7 +353,7 @@ async def close_transport_task_coro():
353353
assert count > 0
354354

355355

356-
async def server_countdown_close_connection_in_middle(ws, path):
356+
async def server_countdown_close_connection_in_middle(ws):
357357
await WebSocketServerHelper.send_connection_ack(ws)
358358

359359
result = await ws.recv()

‎tests/test_phoenix_channel_exceptions.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ def ensure_list(s):
127127
def query_server(server_answers=default_query_server_answer):
128128
from .conftest import PhoenixChannelServerHelper
129129

130-
async def phoenix_server(ws, path):
130+
async def phoenix_server(ws):
131131
await PhoenixChannelServerHelper.send_connection_ack(ws)
132132
await ws.recv()
133133
for server_answer in ensure_list(server_answers):
@@ -138,7 +138,7 @@ async def phoenix_server(ws, path):
138138
return phoenix_server
139139

140140

141-
async def no_connection_ack_phoenix_server(ws, path):
141+
async def no_connection_ack_phoenix_server(ws):
142142
from .conftest import PhoenixChannelServerHelper
143143

144144
await ws.recv()
@@ -363,7 +363,7 @@ def subscription_server(
363363
from .conftest import PhoenixChannelServerHelper
364364
import json
365365

366-
async def phoenix_server(ws, path):
366+
async def phoenix_server(ws):
367367
await PhoenixChannelServerHelper.send_connection_ack(ws)
368368
await ws.recv()
369369
if server_answers is not None:

‎tests/test_phoenix_channel_query.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ def ws_server_helper(request):
3838
yield PhoenixChannelServerHelper
3939

4040

41-
async def query_server(ws, path):
41+
async def query_server(ws):
4242
from .conftest import PhoenixChannelServerHelper
4343

4444
await PhoenixChannelServerHelper.send_connection_ack(ws)
@@ -185,7 +185,7 @@ async def test_phoenix_channel_query_ssl_self_cert_fail(
185185
)
186186

187187

188-
async def subscription_server(ws, path):
188+
async def subscription_server(ws):
189189
from .conftest import PhoenixChannelServerHelper
190190

191191
await PhoenixChannelServerHelper.send_connection_ack(ws)

‎tests/test_phoenix_channel_subscription.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@
7777
)
7878

7979

80-
async def server_countdown(ws, path):
80+
async def server_countdown(ws):
8181
import websockets
8282

8383
from .conftest import MS, PhoenixChannelServerHelper
@@ -295,7 +295,7 @@ async def testing_stopping_without_break():
295295
)
296296

297297

298-
async def phoenix_heartbeat_server(ws, path):
298+
async def phoenix_heartbeat_server(ws):
299299
import websockets
300300

301301
from .conftest import PhoenixChannelServerHelper

‎tests/test_websocket_exceptions.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ async def test_websocket_invalid_query(event_loop, client_and_server, query_str)
6969
"""
7070

7171

72-
async def server_invalid_subscription(ws, path):
72+
async def server_invalid_subscription(ws):
7373
await WebSocketServerHelper.send_connection_ack(ws)
7474
await ws.recv()
7575
await ws.send(invalid_query1_server_answer.format(query_id=1))
@@ -105,7 +105,7 @@ async def test_websocket_invalid_subscription(event_loop, client_and_server, que
105105
)
106106

107107

108-
async def server_no_ack(ws, path):
108+
async def server_no_ack(ws):
109109
await ws.wait_closed()
110110

111111

@@ -124,7 +124,7 @@ async def test_websocket_server_does_not_send_ack(event_loop, server, query_str)
124124
pass
125125

126126

127-
async def server_connection_error(ws, path):
127+
async def server_connection_error(ws):
128128
await WebSocketServerHelper.send_connection_ack(ws)
129129
result = await ws.recv()
130130
print(f"Server received: {result}")
@@ -151,7 +151,7 @@ async def test_websocket_sending_invalid_data(event_loop, client_and_server, que
151151
)
152152

153153

154-
async def server_invalid_payload(ws, path):
154+
async def server_invalid_payload(ws):
155155
await WebSocketServerHelper.send_connection_ack(ws)
156156
result = await ws.recv()
157157
print(f"Server received: {result}")
@@ -244,7 +244,7 @@ async def test_websocket_transport_protocol_errors(event_loop, client_and_server
244244
await session.execute(query)
245245

246246

247-
async def server_without_ack(ws, path):
247+
async def server_without_ack(ws):
248248
# Sending something else than an ack
249249
await WebSocketServerHelper.send_complete(ws, 1)
250250
await ws.wait_closed()
@@ -265,7 +265,7 @@ async def test_websocket_server_does_not_ack(event_loop, server):
265265
pass
266266

267267

268-
async def server_closing_directly(ws, path):
268+
async def server_closing_directly(ws):
269269
await ws.close()
270270

271271

@@ -285,7 +285,7 @@ async def test_websocket_server_closing_directly(event_loop, server):
285285
pass
286286

287287

288-
async def server_closing_after_ack(ws, path):
288+
async def server_closing_after_ack(ws):
289289
await WebSocketServerHelper.send_connection_ack(ws)
290290
await ws.close()
291291

@@ -309,7 +309,7 @@ async def test_websocket_server_closing_after_ack(event_loop, client_and_server)
309309
await session.execute(query)
310310

311311

312-
async def server_sending_invalid_query_errors(ws, path):
312+
async def server_sending_invalid_query_errors(ws):
313313
await WebSocketServerHelper.send_connection_ack(ws)
314314
invalid_error = (
315315
'{"type":"error","id":"404","payload":'

‎tests/test_websocket_query.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,7 @@ async def test_websocket_two_queries_in_series(
214214
assert result1 == result2
215215

216216

217-
async def server1_two_queries_in_parallel(ws, path):
217+
async def server1_two_queries_in_parallel(ws):
218218
await WebSocketServerHelper.send_connection_ack(ws)
219219
result = await ws.recv()
220220
print(f"Server received: {result}", file=sys.stderr)
@@ -261,7 +261,7 @@ async def task2_coro():
261261
assert result1 == result2
262262

263263

264-
async def server_closing_while_we_are_doing_something_else(ws, path):
264+
async def server_closing_while_we_are_doing_something_else(ws):
265265
await WebSocketServerHelper.send_connection_ack(ws)
266266
result = await ws.recv()
267267
print(f"Server received: {result}", file=sys.stderr)
@@ -402,7 +402,7 @@ async def test_websocket_trying_to_connect_to_already_connected_transport(
402402
pass
403403

404404

405-
async def server_with_authentication_in_connection_init_payload(ws, path):
405+
async def server_with_authentication_in_connection_init_payload(ws):
406406
# Wait the connection_init message
407407
init_message_str = await ws.recv()
408408
init_message = json.loads(init_message_str)
@@ -545,7 +545,7 @@ async def test_websocket_add_extra_parameters_to_connect(event_loop, server):
545545
await session.execute(query)
546546

547547

548-
async def server_sending_keep_alive_before_connection_ack(ws, path):
548+
async def server_sending_keep_alive_before_connection_ack(ws):
549549
await WebSocketServerHelper.send_keepalive(ws)
550550
await WebSocketServerHelper.send_keepalive(ws)
551551
await WebSocketServerHelper.send_keepalive(ws)

‎tests/test_websocket_subscription.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
logged_messages: List[str] = []
2828

2929

30-
async def server_countdown(ws, path):
30+
async def server_countdown(ws):
3131
import websockets
3232

3333
logged_messages.clear()
@@ -274,7 +274,7 @@ async def close_transport_task_coro():
274274
assert count > 0
275275

276276

277-
async def server_countdown_close_connection_in_middle(ws, path):
277+
async def server_countdown_close_connection_in_middle(ws):
278278
await WebSocketServerHelper.send_connection_ack(ws)
279279

280280
result = await ws.recv()

0 commit comments

Comments
 (0)
Please sign in to comment.