(self, item)
| 72 | self._notify(requestId, e) |
| 73 | |
| 74 | def _onReceive(self, item): |
| 75 | if item == self._readSentinel: |
| 76 | frame = item |
| 77 | self._shutdown() |
| 78 | self._writer.join() |
| 79 | requestIds = list(self._in) |
| 80 | else: |
| 81 | (requestId, frame) = item |
| 82 | requestIds = [requestId] |
| 83 | |
| 84 | for requestId in requestIds: |
| 85 | self._notify(requestId, frame) |
| 86 | |
| 87 | def _shutdown(self): |
| 88 | with self._lock: |