(self, protocol_factory, pipe)
| 1722 | return transport, protocol |
| 1723 | |
| 1724 | async def connect_write_pipe(self, protocol_factory, pipe): |
| 1725 | protocol = protocol_factory() |
| 1726 | waiter = self.create_future() |
| 1727 | transport = self._make_write_pipe_transport(pipe, protocol, waiter) |
| 1728 | |
| 1729 | try: |
| 1730 | await waiter |
| 1731 | except: |
| 1732 | transport.close() |
| 1733 | raise |
| 1734 | |
| 1735 | if self._debug: |
| 1736 | logger.debug('Write pipe %r connected: (%r, %r)', |
| 1737 | pipe.fileno(), transport, protocol) |
| 1738 | return transport, protocol |
| 1739 | |
| 1740 | def _log_subprocess(self, msg, stdin, stdout, stderr): |
| 1741 | info = [msg] |
nothing calls this directly
no test coverage detected