Remove a stream after processing is complete. Args: stream_id: The stream ID to clean up
(self, stream_id)
| 645 | return self._closed |
| 646 | |
| 647 | def cleanup_stream(self, stream_id): |
| 648 | """Remove a stream after processing is complete. |
| 649 | |
| 650 | Args: |
| 651 | stream_id: The stream ID to clean up |
| 652 | """ |
| 653 | self.streams.pop(stream_id, None) |
| 654 | |
| 655 | def __repr__(self): |
| 656 | return ( |
no outgoing calls