(self, protocol_factory, pipe)
| 1704 | return transport, protocol |
| 1705 | |
| 1706 | async def connect_write_pipe(self, protocol_factory, pipe): |
| 1707 | protocol = protocol_factory() |
| 1708 | waiter = self.create_future() |
| 1709 | transport = self._make_write_pipe_transport(pipe, protocol, waiter) |
| 1710 | |
| 1711 | try: |
| 1712 | await waiter |
| 1713 | except: |
| 1714 | transport.close() |
| 1715 | raise |
| 1716 | |
| 1717 | if self._debug: |
| 1718 | logger.debug('Write pipe %r connected: (%r, %r)', |
| 1719 | pipe.fileno(), transport, protocol) |
| 1720 | return transport, protocol |
| 1721 | |
| 1722 | def _log_subprocess(self, msg, stdin, stdout, stderr): |
| 1723 | info = [msg] |
nothing calls this directly
no test coverage detected