We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 09722ac commit 50057c4Copy full SHA for 50057c4
src/hypercorn/protocol/h2.py
@@ -215,7 +215,10 @@ async def stream_send(self, event: StreamEvent) -> None:
215
await self.has_data.set()
216
await self.stream_buffers[event.stream_id].drain()
217
elif isinstance(event, Trailers):
218
- self.connection.send_headers(event.stream_id, event.headers)
+ self.priority.unblock(event.stream_id)
219
+ await self.has_data.set()
220
+ await self.stream_buffers[event.stream_id].drain()
221
+ self.connection.send_headers(event.stream_id, event.headers, end_stream=True)
222
await self._flush()
223
elif isinstance(event, StreamClosed):
224
await self._close_stream(event.stream_id)
0 commit comments