Remove streamSpawnUri and mangler.

tests/isolate/isolate_complex_messages_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.
+
+// Dart test program for testing isolate communication with
+// complex messages.
+
+library IsolateComplexMessagesTest;
+import 'dart:isolate';
+import '../../pkg/unittest/lib/unittest.dart';
+
+main() {
+  test("complex messages are serialized correctly", () {
+    var box = new MessageBox();
+    IsolateSink remote = streamSpawnFunction(logMessages);
+    remote.add(1);
+    remote.add("Hello");
+    remote.add("World");
+    remote.add(const [null, 1, 2, 3, 4]);
+    remote.add(const [1, 2.0, true, false, 0xffffffffff]);
+    remote.add(const ["Hello", "World", 0xffffffffff]);
+    remote.add(box.sink);
+    remote.close();
+    box.stream.single.then((message) {
+      expect(message, 7);
+    });
+  });
+}
+
+
+void logMessages() {
+  int count = 0;
+  IsolateSink replySink;
+
+  stream.listen((message) {
+    switch (count) {
+      case 0:
+        expect(message, 1);
+        break;
+      case 1:
+        expect(message, "Hello");
+        break;
+      case 2:
+        expect(message, "World");
+        break;
+      case 3:
+        expect(message.length, 5);
+        expect(message[0], null);
+        expect(message[1], 1);
+        expect(message[2], 2);
+        expect(message[3], 3);
+        expect(message[4], 4);
+        break;
+      case 4:
+        expect(message.length, 5);
+        expect(message[0], 1);
+        expect(message[1], 2.0);
+        expect(message[2], true);
+        expect(message[3], false);
+        expect(message[4], 0xffffffffff);
+        break;
+      case 5:
+        expect(message.length, 3);
+        expect(message[0], "Hello");
+        expect(message[1], "World");
+        expect(message[2], 0xffffffffff);
+        break;
+      case 6:
+        replySink = message;
+        break;
+    }
+    count++;
+  },
+  onDone: () {
+    replySink.add(count);
+    replySink.close();
+  });
+}