(self, protocol_factory, address)
| 336 | self._self_reading_future = None |
| 337 | |
| 338 | async def create_pipe_connection(self, protocol_factory, address): |
| 339 | f = self._proactor.connect_pipe(address) |
| 340 | pipe = await f |
| 341 | protocol = protocol_factory() |
| 342 | trans = self._make_duplex_pipe_transport(pipe, protocol, |
| 343 | extra={'addr': address}) |
| 344 | return trans, protocol |
| 345 | |
| 346 | async def start_serving_pipe(self, protocol_factory, address): |
| 347 | server = PipeServer(address) |