(self, protocol_factory, pipe)
| 1706 | return transport, protocol |
| 1707 | |
| 1708 | async def connect_read_pipe(self, protocol_factory, pipe): |
| 1709 | protocol = protocol_factory() |
| 1710 | waiter = self.create_future() |
| 1711 | transport = self._make_read_pipe_transport(pipe, protocol, waiter) |
| 1712 | |
| 1713 | try: |
| 1714 | await waiter |
| 1715 | except: |
| 1716 | transport.close() |
| 1717 | raise |
| 1718 | |
| 1719 | if self._debug: |
| 1720 | logger.debug('Read pipe %r connected: (%r, %r)', |
| 1721 | pipe.fileno(), transport, protocol) |
| 1722 | return transport, protocol |
| 1723 | |
| 1724 | async def connect_write_pipe(self, protocol_factory, pipe): |
| 1725 | protocol = protocol_factory() |
nothing calls this directly
no test coverage detected