blob: b0d2c7a057943e93cf1b1787a85c6e02cc66bced [file] [log] [blame]
/*
* Copyright (c) 2011, 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.
*/
/**
* @assertion Future<Isolate> spawn(void entryPoint(message), message)
* Creates and spawns an isolate that shares the same code as the current isolate.
* The entry-point function is invoked with the initial message.
* @description Checks spawning 3 isolates for one function.
* @author kaigorodov
*/
import "dart:isolate";
import "../../../Utils/expect.dart";
import "../../../Utils/async_utils.dart";
var expectedMessage="message";
class Connection {
var receivePort = new ReceivePort();
void receiveHandler(var message) {
Expect.equals(expectedMessage, message);
receivePort.close();
asyncEnd();
}
start() {
asyncStart();
Isolate.spawn(iMain, receivePort.sendPort);
receivePort.listen(receiveHandler);
}
}
void iMain(SendPort replyPort) {
replyPort.send(expectedMessage);
}
main() {
for (int k=0; k<3; k++) {
new Connection().start();
}
}