def read(self):
if self.done_f.done():<EOL><INDENT>raise BrokenPipeError<EOL><DEDENT>try:<EOL><INDENT>result = yield From(read_message_from_pipe(self.pipe_instance.pipe_handle))<EOL>raise Return(result)<EOL><DEDENT>except BrokenPipeError:<EOL><INDENT>self.done_f.set_result(None)<EOL>raise<EOL><DEDENT>
(coroutine)
Read a single message from the pipe. (Return as text.)