blob: 110377561708c905dbff4162fe8225acf4642680 [file] [log] [blame]
// 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.
/// @assertion void ping(
/// SendPort responsePort, {
/// Object response,
/// int priority: IMMEDIATE
/// })
/// Request that the isolate send response on the responsePort.
/// If the isolate is alive, it will eventually send response (defaulting
/// to null) on the response port.
///
/// @description Check various values for response argument in ping().
/// The isolate is continuously running. Priority is default.
///
/// @author a.semenov@unipro.ru
import "dart:isolate";
import "dart:math";
import "dart:async";
import "../../../Utils/expect.dart";
entryPoint(message){
Random random = new Random();
int s = 0;
while (true){
s = -s + random.nextInt(100);
}
}
Future test(List<Object?> values) async {
ReceivePort onExit = new ReceivePort();
Isolate isolate = await Isolate.spawn(
entryPoint,
null, // message
onExit:onExit.sendPort,
errorsAreFatal:true
);
// check
for (Object? value in values) {
ReceivePort pingPort = new ReceivePort();
isolate.ping(pingPort.sendPort, response:value);
Expect.equals(value, await pingPort.first);
}
// clean up
isolate.kill(priority:Isolate.immediate);
await onExit.first;
asyncEnd();
}
main() {
asyncStart();
test([
null,
0, 1, -1, 10, -100,
true, false,
"", "string",
1.1, double.nan, double.infinity, 0.0
]);
}