Index: third_party/mojo/src/mojo/edk/system/message_pipe_endpoint.cc |
diff --git a/third_party/mojo/src/mojo/edk/system/message_pipe_endpoint.cc b/third_party/mojo/src/mojo/edk/system/message_pipe_endpoint.cc |
index 4b8bc5e0afce17d924d55f0937df44315f790ea0..1522373616ffe147bf0c970bb7e71f7f045de9e7 100644 |
--- a/third_party/mojo/src/mojo/edk/system/message_pipe_endpoint.cc |
+++ b/third_party/mojo/src/mojo/edk/system/message_pipe_endpoint.cc |
@@ -44,6 +44,17 @@ void MessagePipeEndpoint::RemoveAwakable(Awakable* /*awakable*/, |
*signals_state = HandleSignalsState(); |
} |
+MojoResult MessagePipeEndpoint::SetAsyncMessageCallback( |
+ const AsyncMessageCallback& callback) { |
+ NOTREACHED(); |
+ return MOJO_RESULT_INTERNAL; |
+} |
+ |
+void MessagePipeEndpoint::OnReadMessage( |
+ MessageInTransit::ReadContext& reading_message) { |
+ EnqueueMessage(reading_message.PassMessage()); |
+} |
+ |
void MessagePipeEndpoint::Attach(ChannelEndpoint* /*channel_endpoint*/) { |
NOTREACHED(); |
} |