response.raw_headers = message["headers"]
return response
- send_stream, recv_stream = anyio.create_memory_object_stream[Message]()
+ streams: anyio.create_memory_object_stream[Message] = anyio.create_memory_object_stream()
+ send_stream, recv_stream = streams
- with recv_stream, send_stream, collapse_excgroups():
- async with anyio.create_task_group() as task_group:
+ with recv_stream, send_stream:
+ async with create_collapsing_task_group() as task_group:
response = await self.dispatch_func(request, call_next)
await response(scope, wrapped_receive, send)
response_sent.set()