tests/language/async_star/cancel_while_paused_at_yield_test.dart

// Copyright (c) 2020, 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:async';

import 'package:expect/legacy/async_minitest.dart'; // ignore: deprecated_member_use

import 'utils.dart';

main() {
  test('canceling while paused at yield', () {
    var list = [];
    var sync = Sync();
    f() async* {
      list.add('*1');
      yield 1;
      await sync.wait();
      sync.release();
      list.add('*2');
      yield 2;
      list.add('*3');
    }

    var stream = f();
    // TODO(jmesserly): added workaround for:
    // https://github.com/dart-lang/dev_compiler/issues/269
    var sub = stream.listen((x) => list.add(x));
    return sync
        .wait()
        .whenComplete(() {
          expect(list, equals(['*1', 1]));
          sub.pause();
          return sync.wait();
        })
        .whenComplete(() {
          expect(list, equals(['*1', 1, '*2']));
          sub.cancel();
          return Future.delayed(ms * 200, () {
            // Should not have yielded 2 or added *3 while paused.
            expect(list, equals(['*1', 1, '*2']));
          });
        });
  });
}