Perform cleanup when a stream is closed
(self, stream_id: int)
| 189 | self._write_to_transport() |
| 190 | |
| 191 | def pop_stream(self, stream_id: int) -> Stream: |
| 192 | """Perform cleanup when a stream is closed""" |
| 193 | stream = self.streams.pop(stream_id) |
| 194 | self.metadata["active_streams"] -= 1 |
| 195 | self._send_pending_requests() |
| 196 | return stream |
| 197 | |
| 198 | def _new_stream(self, request: Request, spider: Spider) -> Stream: |
| 199 | """Instantiates a new Stream object""" |
no test coverage detected