| Index: tests/isolate/message_stream2_test.dart
|
| diff --git a/tests/isolate/message_stream2_test.dart b/tests/isolate/message_stream2_test.dart
|
| deleted file mode 100644
|
| index c9a6a6702c240987883651f4a7847625f0398764..0000000000000000000000000000000000000000
|
| --- a/tests/isolate/message_stream2_test.dart
|
| +++ /dev/null
|
| @@ -1,76 +0,0 @@
|
| -// 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 serialization of messages.
|
| -// VMOptions=--enable_type_checks --enable_asserts
|
| -
|
| -library Message2Test;
|
| -import 'dart:isolate';
|
| -import '../../pkg/unittest/lib/unittest.dart';
|
| -
|
| -// ---------------------------------------------------------------------------
|
| -// Message passing test 2.
|
| -// ---------------------------------------------------------------------------
|
| -
|
| -class MessageTest {
|
| - static void mapEqualsDeep(Map expected, Map actual) {
|
| - expect(expected, isMap);
|
| - expect(actual, isMap);
|
| - expect(actual.length, expected.length);
|
| - testForEachMap(key, value) {
|
| - if (value is List) {
|
| - listEqualsDeep(value, actual[key]);
|
| - } else {
|
| - expect(actual[key], value);
|
| - }
|
| - }
|
| - expected.forEach(testForEachMap);
|
| - }
|
| -
|
| - static void listEqualsDeep(List expected, List actual) {
|
| - for (int i = 0; i < expected.length; i++) {
|
| - if (expected[i] is List) {
|
| - listEqualsDeep(expected[i], actual[i]);
|
| - } else if (expected[i] is Map) {
|
| - mapEqualsDeep(expected[i], actual[i]);
|
| - } else {
|
| - expect(actual[i], expected[i]);
|
| - }
|
| - }
|
| - }
|
| -}
|
| -
|
| -void pingPong() {
|
| - bool isFirst = true;
|
| - IsolateSink replyTo;
|
| - stream.listen((var message) {
|
| - if (isFirst) {
|
| - isFirst = false;
|
| - replyTo = message;
|
| - return;
|
| - }
|
| - // Bounce the received object back so that the sender
|
| - // can make sure that the object matches.
|
| - replyTo.add(message);
|
| - });
|
| -}
|
| -
|
| -main() {
|
| - test("map is equal after it is sent back and forth", () {
|
| - IsolateSink remote = streamSpawnFunction(pingPong);
|
| - Map m = new Map();
|
| - m[1] = "eins";
|
| - m[2] = "deux";
|
| - m[3] = "tre";
|
| - m[4] = "four";
|
| - MessageBox box = new MessageBox();
|
| - remote.add(box.sink);
|
| - remote.add(m);
|
| - box.stream.listen(expectAsync1((var received) {
|
| - MessageTest.mapEqualsDeep(m, received);
|
| - remote.close();
|
| - box.stream.close();
|
| - }));
|
| - });
|
| -}
|
|
|