Remove a stream after processing is complete.
(self, stream_id)
| 581 | return self._closed |
| 582 | |
| 583 | def cleanup_stream(self, stream_id): |
| 584 | """Remove a stream after processing is complete.""" |
| 585 | self.streams.pop(stream_id, None) |
| 586 | |
| 587 | def __repr__(self): |
| 588 | return ( |
no outgoing calls