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.then((var msg) {
+      completer.close();
       complete(msg[0]);
     });
     sendCompleter.addCompleteHandler((SendPort port) {
       port.send([completer.toSendPort()], null);
     });
   }
 }
 
 class PromiseImpl<T> implements Promise<T> {
 
@@ skipping 334 matching lines @@
         }
         // 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) {
+            port.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;
 
 }