SendPort + ReceivePort changes:

lib/isolate/frog/messages.dart

 // Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 // Defines message visitors, serialization, and deserialization.
 
 /** Serialize [message] (or simulate serialization). */
 _serializeMessage(message) {
   if (_globalState.needSerialization) {
     return new _Serializer().traverse(message);
@@ skipping 52 matching lines @@
     return _getAttachedInfo(o);
   }
 
   _dispatch(var x) {
     if (isPrimitive(x)) return visitPrimitive(x);
     if (x is List) return visitList(x);
     if (x is Map) return visitMap(x);
     if (x is _NativeJsSendPort) return visitNativeJsSendPort(x);
     if (x is _WorkerSendPort) return visitWorkerSendPort(x);
     if (x is _BufferingSendPort) return visitBufferingSendPort(x);
-    if (x is _ReceivePortImpl) return visitReceivePort(x);
-    if (x is _ReceivePortSingleShotImpl) return visitReceivePortSingleShot(x);
     // TODO(floitsch): make this a real exception. (which one)?
     throw "Message serialization: Illegal value $x passed";
   }
 
   abstract visitPrimitive(x);
   abstract visitList(List x);
   abstract visitMap(Map x);
   abstract visitNativeJsSendPort(_NativeJsSendPort x);
   abstract visitWorkerSendPort(_WorkerSendPort x);
   abstract visitBufferingSendPort(_BufferingSendPort x);
-  abstract visitReceivePort(_ReceivePortImpl x);
-  abstract visitReceivePortSingleShot(_ReceivePortSingleShotImpl x);
 
   _clearAttachedInfo(var o) native
       "o['__MessageTraverser__attached_info__'] = (void 0);";
 
   _setAttachedInfo(var o, var info) native
       "o['__MessageTraverser__attached_info__'] = info;";
 
   _getAttachedInfo(var o) native
       "return o['__MessageTraverser__attached_info__'];";
 
@@ skipping 54 matching lines @@
 
   SendPort visitBufferingSendPort(_BufferingSendPort port) {
     if (port._port != null) {
       return _visitNativeOrWorkerPort(port._port);
     } else {
       // TODO(floitsch): Use real exception (which one?).
       throw "internal error: must call _waitForPendingPorts to ensure all"
           + " ports are resolved at this point.";
     }
   }
-
-  SendPort visitReceivePort(_ReceivePortImpl port) {
-    return port.toSendPort();
-  }
-
-  SendPort visitReceivePortSingleShot(_ReceivePortSingleShotImpl port) {
-    return port.toSendPort();
-  }
 }
 
 /** Visitor that serializes a message as a JSON array. */
 class _Serializer extends _MessageTraverser {
   int _nextFreeRefId = 0;
 
   _Serializer() : super();
 
   visitPrimitive(x) => x;
 
@@ skipping 32 matching lines @@
   visitBufferingSendPort(_BufferingSendPort port) {
     if (port._port != null) {
       return _visitNativeOrWorkerPort(port._port);
     } else {
       // TODO(floitsch): Use real exception (which one?).
       throw "internal error: must call _waitForPendingPorts to ensure all"
           + " ports are resolved at this point.";
     }
   }
 
-  visitReceivePort(_ReceivePortImpl port) {
-    return visitNativeJsSendPort(port.toSendPort());;
-  }
-
-  visitReceivePortSingleShot(_ReceivePortSingleShotImpl port) {
-    return visitNativeJsSendPort(port.toSendPort());
-  }
-
   _serializeList(List list) {
     int len = list.length;
     var result = new List(len);
     for (int i = 0; i < len; i++) {
       result[i] = _dispatch(list[i]);
     }
     return result;
   }
 }
 
@@ skipping 86 matching lines @@
     return new _Copier().traverse(x);
   }
 
   // only visible for testing purposes
   static serialize(x) {
     _Serializer serializer = new _Serializer();
     _Deserializer deserializer = new _Deserializer();
     return deserializer.deserialize(serializer.traverse(x));
   }
 }