SendPort + ReceivePort changes:

lib/isolate/frog/ports.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.
 
 /** Common functionality to all send ports. */
 class _BaseSendPort implements SendPort {
   /** Id for the destination isolate. */
   final int _isolateId;
 
   _BaseSendPort(this._isolateId);
 
-  _ReceivePortSingleShotImpl call(var message) {
-    final result = new _ReceivePortSingleShotImpl();
-    this.send(message, result.toSendPort());
-    return result;
-  }
-
   static void checkReplyTo(SendPort replyTo) {
     if (replyTo !== null
         && replyTo is! _NativeJsSendPort
         && replyTo is! _WorkerSendPort
         && replyTo is! _BufferingSendPort) {
       throw new Exception("SendPort.send: Illegal replyTo port type");
     }
   }
 
-  // TODO(sigmund): replace the current SendPort.call with the following:
-  //Future call(var message) {
-  //   final completer = new Completer();
-  //   final port = new _ReceivePort.singleShot();
-  //   send(message, port.toSendPort());
-  //   port.receive((value, ignoreReplyTo) {
-  //     if (value is Exception) {
-  //       completer.completeException(value);
-  //     } else {
-  //       completer.complete(value);
-  //     }
-  //   });
-  //   return completer.future;
-  //}
+  Future call(var message) {
+    final completer = new Completer();
+    final port = new _ReceivePortImpl();
+    send(message, port.toSendPort());
+    port.receive((value, ignoreReplyTo) {
+      port.close();
+      if (value is Exception) {
+        completer.completeException(value);
+      } else {
+        completer.complete(value);
+      }
+    });
+    return completer.future;
+  }
 
   abstract void send(var message, [SendPort replyTo]);
   abstract bool operator ==(var other);
   abstract int hashCode();
 }
 
 /** A send port that delivers messages in-memory via native JavaScript calls. */
 class _NativeJsSendPort extends _BaseSendPort implements SendPort {
   final _ReceivePortImpl _receivePort;
 
@@ skipping 129 matching lines @@
   int hashCode() => _id;
 }
 
 /** Default factory for receive ports. */
 class _ReceivePortFactory {
 
   factory ReceivePort() {
     return new _ReceivePortImpl();
   }
 
-  factory ReceivePort.singleShot() {
-    return new _ReceivePortSingleShotImpl();
-  }
 }
 
 /** Implementation of a multi-use [ReceivePort] on top of JavaScript. */
 class _ReceivePortImpl implements ReceivePort {
   int _id;
   Function _callback;
   static int _nextFreeId = 1;
 
   _ReceivePortImpl()
       : _id = _nextFreeId++ {
     _globalState.currentContext.register(_id, this);
   }
 
   void receive(void onMessage(var message, SendPort replyTo)) {
     _callback = onMessage;
   }
 
   void close() {
     _callback = null;
     _globalState.currentContext.unregister(_id);
   }
 
   SendPort toSendPort() {
     return new _NativeJsSendPort(this, _globalState.currentContext.id);
   }
 }
 
-/** Implementation of a single-shot [ReceivePort]. */
-class _ReceivePortSingleShotImpl implements ReceivePort {
-
-  _ReceivePortSingleShotImpl() : _port = new _ReceivePortImpl() { }
-
-  void receive(void callback(var message, SendPort replyTo)) {
-    _port.receive((var message, SendPort replyTo) {
-      _port.close();
-      callback(message, replyTo);
-    });
-  }
-
-  void close() {
-    _port.close();
-  }
-
-  SendPort toSendPort() => _port.toSendPort();
-
-  final _ReceivePortImpl _port;
-}
-
 /** Wait until all ports in a message are resolved. */
 _waitForPendingPorts(var message, void callback()) {
   final finder = new _PendingSendPortFinder();
   finder.traverse(message);
   Futures.wait(finder.ports).then((_) => callback());
 }
 
 
 /** Visitor that finds all unresolved [SendPort]s in a message. */
 class _PendingSendPortFinder extends _MessageTraverser {
   List<Future<SendPort>> ports;
   _PendingSendPortFinder() : super(), ports = [];
 
   visitPrimitive(x) {}
   visitNativeJsSendPort(_NativeJsSendPort port) {}
   visitWorkerSendPort(_WorkerSendPort port) {}
-  visitReceivePort(_ReceivePortImpl port) {}
-  visitReceivePortSingleShot(_ReceivePortSingleShotImpl port) {}
 
   visitList(List list) {
     final visited = _getInfo(list);
     if (visited !== null) return;
     _attachInfo(list, true);
     // TODO(sigmund): replace with the following: (bug #1660)
     // list.forEach(_dispatch);
     list.forEach((e) => _dispatch(e));
   }
 
   visitMap(Map map) {
     final visited = _getInfo(map);
     if (visited !== null) return;
 
     _attachInfo(map, true);
     // TODO(sigmund): replace with the following: (bug #1660)
     // map.getValues().forEach(_dispatch);
     map.getValues().forEach((e) => _dispatch(e));
   }
 
   visitBufferingSendPort(_BufferingSendPort port) {
     if (port._port == null) {
       ports.add(port._futurePort);
     }
   }
 }