Very simple version of Isolates.

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();
-  });
-}