Chromium Code Reviews| Index: tests/isolate/message4_test.dart |
| diff --git a/tests/isolate/message4_test.dart b/tests/isolate/message4_test.dart |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..8baffb3304d2d4c964b9c11253e02807c9c2b7fc |
| --- /dev/null |
| +++ b/tests/isolate/message4_test.dart |
| @@ -0,0 +1,69 @@ |
| +// Copyright (c) 2017, 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 with static |
| +// native functions. |
| + |
| +library MessageTest; |
| + |
| +import 'dart:async'; |
| +import 'dart:collection'; |
| +import 'dart:isolate'; |
| +import 'package:async_helper/async_helper.dart'; |
|
zra
2017/07/21 19:54:16
package: imports should come after all dart: impor
alexmarkov
2017/07/21 20:51:42
Done.
|
| +import 'package:expect/expect.dart'; |
| +import 'dart:typed_data'; |
| + |
| +void echoMain(msg) { |
| + SendPort replyTo = msg[0]; |
| + SendPort pong = msg[1]; |
| + ReceivePort port = new ReceivePort(); |
| + replyTo.send(port.sendPort); |
| + port.listen((msg) { |
| + if (msg == "halt") { |
| + port.close(); |
| + } else { |
| + pong.send(msg); |
| + } |
| + }); |
| +} |
| + |
| +void runTests(SendPort ping, Queue checks) { |
| + ping.send("abc"); |
| + checks.add((x) => Expect.equals("abc", x)); |
| + |
| + ping.send(int.parse); |
| + checks.add((x) => Expect.identical(int.parse, x)); |
| + |
| + ping.send(identityHashCode); |
| + checks.add((x) => Expect.identical(identityHashCode, x)); |
| + |
| + ping.send(identical); |
| + checks.add((x) => Expect.identical(identical, x)); |
| +} |
| + |
| +void main() { |
| + asyncStart(); |
| + Queue checks = new Queue(); |
| + ReceivePort testPort = new ReceivePort(); |
| + Completer completer = new Completer(); |
| + |
| + testPort.listen((msg) { |
| + Function check = checks.removeFirst(); |
| + check(msg); |
| + if (checks.isEmpty) { |
| + completer.complete(); |
| + testPort.close(); |
| + } |
| + }); |
| + |
| + ReceivePort initialReplyPort = new ReceivePort(); |
| + Isolate |
|
zra
2017/07/21 19:54:16
Maybe instead something like:
main() async {
..
alexmarkov
2017/07/21 20:51:42
Done.
|
| + .spawn(echoMain, [initialReplyPort.sendPort, testPort.sendPort]) |
| + .then((_) => initialReplyPort.first) |
| + .then((SendPort ping) { |
| + runTests(ping, checks); |
| + Expect.isTrue(checks.length > 0); |
| + completer.future.then((_) => ping.send("halt")).then((_) => asyncEnd()); |
| + }); |
| +} |