async* फंक्शन बॉडी को क्रियान्वित करने से रोकता है

जब आप async* का उपयोग कर रहे हैं, तो विधि केवल तभी क्रियान्वित होने लगेगी जब लौटे Stream को ग्राहक मिल जाएगा। आपका कोड वास्तव में कोई मतलब नहीं रखता है क्योंकि listen एक विधि लेता है जो void लौटाता है। इसलिए कोई भी लौटाए गए Stream पर सुनने वाला नहीं है, जो दी गई विधि स्वचालित रूप से वापस आ जाएगी (async* कीवर्ड के आधार पर)।

मैं आपके कोड को ठीक से फिर से लिखूंगा ताकि आप listen के बजाय await for का उपयोग करें जो मुझे लगता है कि यह और अधिक स्पष्ट करता है कि क्या होता है:

import 'dart:async';

Future<void> main(List<String> args) async {
  print('====');
  await tranStream();
}

Stream<int> intStreamer() async* {
  int c = 0;
  while (c <= 30) {
    await Future<void>.delayed(const Duration(seconds: 1));
    yield c++;
  }
}

Future<void> tranStream() async {
  await for (final event in intStreamer()) {
    print(event);
  }
}

tranStream के उदाहरण के साथ अपडेट एक स्ट्रीम लौटाता है:

import 'dart:async';

Future<void> main(List<String> args) async {
  print('====');
  await for (final event in tranStream()) {
    print('main got: $event');
  }
}

Stream<int> intStreamer() async* {
  int c = 0;
  while (c <= 30) {
    await Future<void>.delayed(const Duration(seconds: 1));
    yield c++;
  }
}

Stream<int> tranStream() async* {
  await for (final event in intStreamer()) {
    print('tranStream got: $event');
    yield event;
  }
}