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

examples/dart/netcat/lib/main.dart

Index: examples/dart/netcat/lib/main.dart
diff --git a/examples/dart/netcat/lib/main.dart b/examples/dart/netcat/lib/main.dart
index 9e5cc20dd99dc6ba4d4abec8570cdc98a15f0d63..8ac0d3f1e8a63f27453f86fcc3aa85321f0d2a47 100644
--- a/examples/dart/netcat/lib/main.dart
+++ b/examples/dart/netcat/lib/main.dart
@@ -49,7 +49,7 @@ class Connector {
   TcpConnectedSocketProxy _socket;
   MojoDataPipeProducer _socketSender;
   MojoDataPipeConsumer _socketReceiver;
-  MojoEventStream _socketReceiverEventStream;
+  MojoEventHandler _socketReceiverEventHandler;
   final ByteData _readBuffer;
   final ByteData _writeBuffer;
 
@@ -81,8 +81,8 @@ class Connector {
       _startReadingFromTerminal();
 
       // Set up reading from the socket.
-      _socketReceiverEventStream = new MojoEventStream(_socketReceiver.handle);
-      _socketReceiverEventStream.listen(_onSocketReceiverEvent);
+      _socketReceiverEventHandler = new MojoEventHandler(_socketReceiver.handle);
+      _socketReceiverEventHandler.handleEvents(_onSocketReceiverEvent);
     } catch (e) {
       _shutDown();
     }
@@ -130,7 +130,7 @@ class Connector {
         _terminal.ptr.write(_readBuffer.buffer.asUint8List(0, numBytesRead), 0,
                             files.Whence.FROM_CURRENT)
             .catchError((e) { _shutDown(); });
-        _socketReceiverEventStream.enableReadEvents();
+        _socketReceiverEventHandler.enableReadEvents();
       } else {
         shouldShutDown = true;
       }
@@ -145,9 +145,9 @@ class Connector {
   }
 
   void _shutDown() {
-    if (_socketReceiverEventStream != null) {
-      ignoreFuture(_socketReceiverEventStream.close());
-      _socketReceiverEventStream = null;
+    if (_socketReceiverEventHandler != null) {
+      ignoreFuture(_socketReceiverEventHandler.close());
+      _socketReceiverEventHandler = null;
     }
     if (_socketSender != null) {
       if (_socketSender.handle.isValid)
@@ -226,7 +226,7 @@ main(List args) {
   MojoHandle appHandle = new MojoHandle(args[0]);
   String url = args[1];
   new NetcatApplication.fromHandle(appHandle)
-    ..onError = (() {
+    ..onError = ((Object e) {
       MojoHandle.reportLeakedHandles();
     });
 }