(self, transport)
| 38 | return '<{}>'.format(' '.join(info)) |
| 39 | |
| 40 | def connection_made(self, transport): |
| 41 | self._transport = transport |
| 42 | |
| 43 | stdout_transport = transport.get_pipe_transport(1) |
| 44 | if stdout_transport is not None: |
| 45 | self.stdout = streams.StreamReader(limit=self._limit, |
| 46 | loop=self._loop) |
| 47 | self.stdout.set_transport(stdout_transport) |
| 48 | self._pipe_fds.append(1) |
| 49 | |
| 50 | stderr_transport = transport.get_pipe_transport(2) |
| 51 | if stderr_transport is not None: |
| 52 | self.stderr = streams.StreamReader(limit=self._limit, |
| 53 | loop=self._loop) |
| 54 | self.stderr.set_transport(stderr_transport) |
| 55 | self._pipe_fds.append(2) |
| 56 | |
| 57 | stdin_transport = transport.get_pipe_transport(0) |
| 58 | if stdin_transport is not None: |
| 59 | self.stdin = streams.StreamWriter(stdin_transport, |
| 60 | protocol=self, |
| 61 | reader=None, |
| 62 | loop=self._loop) |
| 63 | |
| 64 | def pipe_data_received(self, fd, data): |
| 65 | if fd == 1: |
nothing calls this directly
no test coverage detected