Dart: Use a RawReceivePort to receive events for Mojo handles.

mojo/public/dart/mojo/lib/src/proxy.dart

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 part of bindings;
 
 class ProxyError {
   final String message;
   ProxyError(this.message);
   String toString() => "ProxyError: $message";
 }
 
-abstract class Proxy extends core.MojoEventStreamListener {
-  final Map<int, Completer> _completerMap = {};
+abstract class Proxy extends core.MojoEventHandler {
+  Map<int, Completer> _completerMap = {};
   Completer _errorCompleter = new Completer();
   Set<Completer> _errorCompleters;
   int _nextId = 0;
   int _version = 0;
   int _pendingCount = 0;
 
   Proxy.fromEndpoint(core.MojoMessagePipeEndpoint endpoint)
       : super.fromEndpoint(endpoint);
 
   Proxy.fromHandle(core.MojoHandle handle) : super.fromHandle(handle);
@@ skipping 48 matching lines @@
 
     return super.close(immediate: immediate);
   }
 
   void sendMessage(Struct message, int name) {
     if (!isBound) {
       proxyError("The Proxy is closed.");
       return;
     }
     if (!isOpen) {
-      listen();
+      beginHandlingEvents();
     }
     var header = new MessageHeader(name);
-
     var serviceMessage = message.serializeWithHeader(header);
     endpoint.write(serviceMessage.buffer, serviceMessage.buffer.lengthInBytes,
         serviceMessage.handles);
     if (!endpoint.status.isOk) {
       proxyError("Write to message pipe endpoint failed.");
     }
   }
 
   Future sendMessageWithRequestId(Struct message, int name, int id, int flags) {
     var completer = new Completer();
     if (!isBound) {
       proxyError("The Proxy is closed.");
       return completer.future;
     }
     if (!isOpen) {
-      listen();
+      beginHandlingEvents();
     }
     if (id == -1) {
       id = _nextId++;
     }
 
     var header = new MessageHeader.withRequestId(name, flags, id);
     var serviceMessage = message.serializeWithHeader(header);
     endpoint.write(serviceMessage.buffer, serviceMessage.buffer.lengthInBytes,
         serviceMessage.handles);
 
@@ skipping 127 matching lines @@
 
 // Generated Proxy classes implement this interface.
 abstract class ProxyBase {
   final Proxy impl = null;
   final String name = null;
 }
 
 abstract class ServiceConnector {
   void connectToService(String url, ProxyBase proxy);
 }