Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion src/h2/connection.py
Original file line number Diff line number Diff line change
Expand Up @@ -919,10 +919,14 @@ def end_stream(self, stream_id: int) -> None:
:param stream_id: The ID of the stream to end.
:type stream_id: ``int``
:returns: Nothing
:raises NoSuchStreamError: If the stream ID does not correspond to a
known stream and is higher than the current maximum stream ID.
:raises StreamClosedError: If the stream ID corresponds to a stream
that has been closed.
"""
self.config.logger.debug("End stream ID %d", stream_id)
self.state_machine.process_input(ConnectionInputs.SEND_DATA)
frames = self.streams[stream_id].end_stream()
frames = self._get_stream_by_id(stream_id).end_stream()
self._prepare_for_sending(frames)

def increment_flow_control_window(self, increment: int, stream_id: int | None = None) -> None:
Expand Down