امتلاك اشتراكات التدفق ودلالات التسليم

import 'dart:async';
Stream<int> counts() async* {
  yield 1;
  yield 2;
}
Future<void> main() async {
  await for (final count in counts()) {
    print(count * 10);
  }
  print('done');
}

10
20
done

المخرج المتوقع 10 ثم 20 ثم done. تنتظر الحلقة إتمام التدفق قبل done. لم يُنفذ تدفق أو مجدول أو اختبار توقيت.

import 'dart:async';
Future<void> main() async {
  final source = Stream<int>.error(const FormatException('synthetic sample'));
  try {
    await for (final value in source) {
      print(value);
    }
  } on FormatException {
    print('stream rejected');
  }
  print('consumer finished');
}

stream rejected
consumer finished

المخرج المتوقع stream rejected ثم consumer finished. لا يطبع حدث بيانات. لم يُترجم أو ينفذ ولا يتصل بمصدر تدفق حقيقي.