Remove streamSpawnUri and mangler.

tests/isolate/mandel_isolate_stream_test.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.
 
 library MandelIsolateTest;
 import 'dart:async';
 import 'dart:isolate';
 import 'dart:math';
 import '../../pkg/unittest/lib/unittest.dart';
 
@@ skipping 68 matching lines @@
   List<LineProcessorClient> _lineProcessedBy;
   int _sent;
   int _missing;
   Completer<bool> _validated;
 }
 
 
 class LineProcessorClient {
 
   LineProcessorClient(MandelbrotState this._state, int this._id) {
-    _port = spawnFunction(processLines);
+    _sink = streamSpawnFunction(processLines);
+    _box = new MessageBox();
+    _sink.add(_box.sink);
+    _box.stream.listen((List<int> message) {
+      _state.notifyProcessedLine(this, _currentLine, message);
+    });
   }
 
   void processLine(int y) {
-    _port.call(y).then((List<int> message) {
-      _state.notifyProcessedLine(this, y, message);
-    });
+    _currentLine = y;
+    _sink.add(y);
   }
 
   void shutdown() {
-    _port.send(TERMINATION_MESSAGE, null);
+    _sink.close();
+    _box.stream.close();
   }
 
   MandelbrotState _state;
   int _id;
-  SendPort _port;
+  IsolateSink _sink;
+  int _currentLine;
+  MessageBox _box;
 }
 
 List<int> processLine(int y) {
   double inverseN = 2.0 / N;
   double Civ = y * inverseN - 1.0;
   List<int> result = new List<int>(N);
   for (int x = 0; x < N; x++) {
     double Crv = x * inverseN - 1.5;
 
     double Zrv = Crv;
@@ skipping 10 matching lines @@
       Trv = Zrv * Zrv;
       Tiv = Ziv * Ziv;
     } while (((Trv + Tiv) <= 4.0) && (--i > 0));
 
     result[x] = i;
   }
   return result;
 }
 
 void processLines() {
-  port.receive((message, SendPort replyTo) {
-    if (message == TERMINATION_MESSAGE) {
-      assert(replyTo == null);
-      port.close();
-    } else {
-      replyTo.send(processLine(message), null);
+  bool isFirst = true;
+  IsolateSink replyTo;
+
+  stream.listen((message) {
+    if (isFirst) {
+      isFirst = false;
+      replyTo = message;
+      return;
     }
+    replyTo.add(processLine(message));
   });
 }