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

benchmarks/mojo_rtt_benchmark/lib/main.dart

 // Copyright 2015 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.
 
 // This Mojo app is a benchmark of Mojo/Dart IPC Round Trip Times.
 // It creates many proxies from a single isolate, and makes requests using those
 // proxies round-robin.
 // To run it, and the other RTT benchmarks:
 //
 // $ ./mojo/devtools/common/mojo_benchmark [--release] mojo/tools/data/rtt_benchmarks
@@ skipping 36 matching lines @@
     if (argResults["cpp-server"]) {
       echoUrl = "mojo:echo_server";
     }
     _numClients = int.parse(argResults["num-clients"]);
     _numActiveClients = int.parse(argResults["num-active-clients"]);
 
     // Setup the connection to the echo app.
     for (int i = 0; i < _numClients; i++) {
       var newProxy = new EchoProxy.unbound();
       newProxy.errorFuture.then((e) {
-        _errorHandler();
+        _errorHandler(e);
       });
       connectToService(echoUrl, newProxy);
       _echoProxies.add(newProxy);
     }
 
     // Start echoing.
     _doEcho = true;
     Timer.run(() => _run(0));
 
     // Begin tracing echo rtts after waiting for kWarmupDuration.
@@ skipping 24 matching lines @@
       int end = getTimeTicksNow();
       _tracing.traceDuration("ping", "mojo_rtt_benchmark", start, end);
       return r;
     });
   }
 
   Future _echo(int idx, String s) {
     return _echoProxies[idx].ptr.echoString(s);
   }
 
-  _errorHandler() {
+  _errorHandler(Object e) {
     _doEcho = false;
     return Future.wait(_echoProxies.map((p) => p.close())).then((_) {
       MojoHandle.reportLeakedHandles();
     });
   }
 }
 
 main(List args) {
   MojoHandle appHandle = new MojoHandle(args[0]);
   new EchoTracingApp.fromHandle(appHandle);
 }