(self, protocol_factory, pipe)
| 1688 | return transport, protocol |
| 1689 | |
| 1690 | async def connect_read_pipe(self, protocol_factory, pipe): |
| 1691 | protocol = protocol_factory() |
| 1692 | waiter = self.create_future() |
| 1693 | transport = self._make_read_pipe_transport(pipe, protocol, waiter) |
| 1694 | |
| 1695 | try: |
| 1696 | await waiter |
| 1697 | except: |
| 1698 | transport.close() |
| 1699 | raise |
| 1700 | |
| 1701 | if self._debug: |
| 1702 | logger.debug('Read pipe %r connected: (%r, %r)', |
| 1703 | pipe.fileno(), transport, protocol) |
| 1704 | return transport, protocol |
| 1705 | |
| 1706 | async def connect_write_pipe(self, protocol_factory, pipe): |
| 1707 | protocol = protocol_factory() |
nothing calls this directly
no test coverage detected