We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5037ad3 commit 15f1573Copy full SHA for 15f1573
1 file changed
tests/shared/test_session.py
@@ -518,8 +518,11 @@ async def test_receive_loop_handles_closed_response_stream():
518
_server_read, server_write = server_streams
519
520
async with ClientSession(read_stream=client_read, write_stream=client_write) as client_session:
521
- response_stream, _ = anyio.create_memory_object_stream[JSONRPCResponse | JSONRPCError](1)
+ response_stream, response_stream_reader = anyio.create_memory_object_stream[
522
+ JSONRPCResponse | JSONRPCError
523
+ ](1)
524
await response_stream.aclose()
525
+ await response_stream_reader.aclose()
526
client_session._response_streams[0] = response_stream
527
528
server_write.close()
0 commit comments