parameters: (self, protocol_factory, pipe)
docstring: Register write pipe in event loop.
  
          protocol_factory should instantiate object with BaseProtocol interface.
          Pipe is file-like object already switched to nonblocking.
          Return pair (transport, protocol), where transport support
          WriteTransport interface.
docstring_summary: Register write pipe in event loop.
docstring_tokens: Register write pipe in event loop .
function: async def connect_write_pipe(self, protocol_factory, pipe):
          """Register write pipe in event loop.
  
          protocol_factory should instantiate object with BaseProtocol interface.
          Pipe is file-like object already switched to nonblocking.
          Return pair (transport, protocol), where transport support
          WriteTransport interface."""
          # The reason to accept file-like object instead of just file descriptor
          # is: we need to own pipe and close it at transport finishing
          # Can got complicated errors if pass f.fileno(),
          # close fd in pipe transport then close f and vise versa.
          raise NotImplementedError
function_tokens: async def connect_write_pipe ( self , protocol_factory , pipe ) : # The reason to accept file-like object instead of just file descriptor # is: we need to own pipe and close it at transport finishing # Can got complicated errors if pass f.fileno(), # close fd in pipe transport then close f and vise versa. raise NotImplementedError