[benchmarks/nnbd] Fix NNBD compile-time errors in benchmarks/Calls

Fixes compile-time errors in vm/dart/async_igoto_threshold_flag_test
which uses Calls benchmark.

Change-Id: I1e3d075bb7f40516c5319e4eb4ebf7dc5b2c7ccb
Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/146700
Reviewed-by: Liam Appelbe <liama@google.com>
Reviewed-by: Régis Crelier <regis@google.com>
Commit-Queue: Alexander Markov <alexmarkov@google.com>
This commit is contained in:
Alexander Markov 2020-05-05 21:07:33 +00:00 committed by commit-bot@chromium.org
parent 1ef444139c
commit 9bba7323a0

View file

@ -105,7 +105,7 @@ main() async {
@pragma('vm:never-inline')
@pragma('dart2js:noInline')
Future<int> performAwaitCallsClosureTargetPolymorphic(
FutureOr fun(int count)) async {
FutureOr<int> fun(int count)) async {
int sum = 0;
for (int i = 0; i < iterationLimitAsync; ++i) {
sum += await fun(i);
@ -330,7 +330,7 @@ Stream<int> generateNumbersAsyncStar2(int limit) async* {
@pragma('dart2js:noInline')
Stream<int> generateNumbersManualAsync(int limit) {
int current = 0;
StreamController<int> controller;
StreamController<int> controller = StreamController(sync: true);
void emit() {
while (true) {
if (controller.isPaused || !controller.hasListener) return;
@ -347,7 +347,9 @@ Stream<int> generateNumbersManualAsync(int limit) {
scheduleMicrotask(emit);
}
controller = StreamController(onListen: run, onResume: run, sync: true);
controller.onListen = run;
controller.onResume = run;
return controller.stream;
}