SendPort + ReceivePort changes:

samples/proxy/promise.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.
 
 /** A library to illustrate pipelining. */
 #library("promise");
 #import("dart:isolate");
 
 /** A promise to value of type [T] that may be computed asynchronously. */
 // TODO(sigmund,benl): remove Promise<T> use Future<T> instead.
@@ skipping 153 matching lines @@
 
 }
 
 // When a promise is sent across a port, it is converted to a
 // Promise<SendPort> down which we must send a port to receive the
 // completion value. Hand the Promise<SendPort> to this class to deal
 // with it.
 
 class PromiseProxy<T> extends PromiseImpl<T> {
   PromiseProxy(Promise<SendPort> sendCompleter) {
-    ReceivePort completer = new ReceivePort.singleShot();
-    completer.receive((var msg, SendPort _) {
+    ReceivePort completer = new ReceivePort();
+    completer.receive((var msg, _) {
+      completer.close();
       complete(msg[0]);
     });
     sendCompleter.addCompleteHandler((SendPort port) {
       port.send([completer.toSendPort()], null);
     });
   }
 }
 
 class PromiseImpl<T> implements Promise<T> {
 
@@ skipping 304 matching lines @@
   }
 
   Promise call(List message) {
     return _marshal(message, (List marshalled) {
       // TODO(kasperl): For now, the [Promise.then] implementation allows
       // me to return a promise and it will do the promise chaining.
       final result = new Promise();
       // The promise queue implementation guarantees that promise is
       // resolved at this point.
       SendPort outgoing = _promise.value;
-      ReceivePort incoming  = outgoing.call(marshalled);
-      incoming.receive((List receiveMessage, replyTo) {
+      outgoing.call(marshalled).then((List receiveMessage) {
         result.complete(receiveMessage[0]);
       });
       return result;
     });
   }
 
   // Marshal the [message] and pass it to the [process] callback
   // function. Any promises are converted to a port which expects to
   // receive a port from the other side down which the remote promise
   // can be completed by sending the promise's completion value.
   Promise _marshal(List message, process(List marshalled)) {
     return _promise.then((SendPort port) {
       List marshalled = new List(message.length);
 
       for (int i = 0; i < marshalled.length; i++) {
         var entry = message[i];
         if (entry is Proxy) {
           entry = entry._promise;
         }
         // Obviously this will be true if [entry] was a Proxy.
         if (entry is Promise) {
           // Note that we could optimise this by just sending the value
           // if the promise is already complete. Let's get this working
           // first!
 
           // This port will receive a SendPort that can be used to
           // signal completion of this promise to the corresponding
           // promise that the other end has created.
-          ReceivePort receiveCompleter = new ReceivePort.singleShot();
+          ReceivePort receiveCompleter = new ReceivePort();
           marshalled[i] = receiveCompleter.toSendPort();
           Promise<SendPort> completer = new Promise<SendPort>();
           receiveCompleter.receive((var msg, SendPort replyPort) {
+            receiveCompleter.close();
             completer.complete(msg[0]);
           });
           entry.addCompleteHandler((value) {
             completer.addCompleteHandler((SendPort completePort) {
               _marshal([value], (List completeMessage) => completePort.send(completeMessage, null));
             });
           });
         } else {
           // FIXME(kasperl, benl): this should probably be a copy?
           marshalled[i] = entry;
         }
         if (marshalled[i] is ReceivePort) {
           throw new Exception("Despite the documentation, you cannot send a ReceivePort");
         } 
       }
       return process(marshalled);
     }).flatten();
   }
 
   Promise<SendPort> _promise;
   static Map<SendPort, Dispatcher> _dispatchers;
 
 }