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