(self, cb, *data)
| 217 | self._pipes_connected = True |
| 218 | |
| 219 | def _call(self, cb, *data): |
| 220 | if self._pending_calls is not None: |
| 221 | self._pending_calls.append((cb, data)) |
| 222 | else: |
| 223 | self._loop.call_soon(cb, *data) |
| 224 | |
| 225 | def _pipe_connection_lost(self, fd, exc): |
| 226 | self._call(self._protocol.pipe_connection_lost, fd, exc) |
no test coverage detected