code: def write(self, message):
          
          if self.done_f.done():
              raise BrokenPipeError
  
          try:
              yield From(write_message_to_pipe(self.pipe_instance.pipe_handle, message))
          except BrokenPipeError:
              self.done_f.set_result(None)
              raise
docs: (coroutine)
          Write a single message into the pipe.