Files
sdk/tests/lib/isolate/pause_test.dart
Robert Nystrom 8a51cb6093 Reformat tests/lib/isolate/** using 3.8 style.
Change-Id: I8fafc8c2788faf848a8a8488b76cb163b7679308
Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/425330
Commit-Queue: Lasse Nielsen <lrn@google.com>
Auto-Submit: Bob Nystrom <rnystrom@google.com>
Reviewed-by: Lasse Nielsen <lrn@google.com>
2025-05-02 04:01:24 -07:00

48 lines
1.3 KiB
Dart

// Copyright (c) 2014, 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.
import "dart:isolate";
import "dart:async";
import "package:expect/async_helper.dart";
isomain1(replyPort) {
RawReceivePort port = new RawReceivePort();
port.handler = (v) {
replyPort.send(v);
port.close();
};
replyPort.send(port.sendPort);
}
main() {
asyncStart();
RawReceivePort reply = new RawReceivePort();
late Isolate isolate;
late Capability resume;
var completer = new Completer(); // Completed by first reply from isolate.
reply.handler = completer.complete;
Isolate.spawn(isomain1, reply.sendPort)
.then((Isolate iso) {
isolate = iso;
return completer.future;
})
.then((echoPort) {
// Isolate has been created, and first response has been returned.
resume = isolate.pause();
echoPort.send(24);
reply.handler = (v) {
throw "RESPONSE WHILE PAUSED?!?";
};
return new Future.delayed(const Duration(milliseconds: 250));
})
.then((_) {
reply.handler = (v) {
if (v != 24) throw "WRONG ANSWER!";
reply.close();
asyncEnd();
};
isolate.resume(resume);
});
}