| Index: tests/isolate/isolate_complex_messages_stream_test.dart
|
| diff --git a/tests/isolate/isolate_complex_messages_stream_test.dart b/tests/isolate/isolate_complex_messages_stream_test.dart
|
| deleted file mode 100644
|
| index 219b289a52bf4ef68018722cdad352c22ebf3332..0000000000000000000000000000000000000000
|
| --- a/tests/isolate/isolate_complex_messages_stream_test.dart
|
| +++ /dev/null
|
| @@ -1,78 +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 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();
|
| - });
|
| -}
|
|
|