(self, exc)
| 1003 | return exc |
| 1004 | |
| 1005 | def error_all_cp_sessions(self, exc): |
| 1006 | stream_ids = list(self._continuous_paging_sessions.keys()) |
| 1007 | for stream_id in stream_ids: |
| 1008 | self._continuous_paging_sessions[stream_id].on_error(exc) |
| 1009 | |
| 1010 | def error_all_requests(self, exc): |
| 1011 | with self.lock: |