| // 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. |
| |
| // VMOptions=--enable-isolate-groups --experimental-enable-isolate-groups-jit |
| // VMOptions=--no-enable-isolate-groups |
| |
| library RequestReplyTest; |
| |
| import 'dart:isolate'; |
| import 'package:async_helper/async_helper.dart'; |
| import 'package:expect/expect.dart'; |
| |
| void entry(initPort) { |
| ReceivePort port = new ReceivePort(); |
| initPort.send(port.sendPort); |
| port.listen((pair) { |
| var message = pair[0]; |
| SendPort replyTo = pair[1]; |
| replyTo.send(message + 87); |
| port.close(); |
| }); |
| } |
| |
| void main([args, port]) { |
| ReceivePort init = new ReceivePort(); |
| Isolate.spawn(entry, init.sendPort); |
| asyncStart(); |
| init.first.then((port) { |
| ReceivePort reply = new ReceivePort(); |
| port.send([99, reply.sendPort]); |
| reply.listen((message) { |
| Expect.equals(message, 99 + 87); |
| reply.close(); |
| asyncEnd(); |
| }); |
| }); |
| } |