dart-streams

readme.md

dart-streams

Created with <3 with dartpad.dev.

main.dart

void main() async {  
  var stream = countStream(10);
  print(stream);
  stream.listen((value) {
    print(value);
  });
  print("after stream");
  stream = countStream(10);
  await for (final value in stream) {
    print(value);
  }
  print("after await");
  stream = countStream(10);
  var transformedStream = stream.where((x) => x % 2 == 0);
  await for (final value in transformedStream) {
    print(value);
  }
  print("after await2");
  stream = countStream(10);
  print(await stream.where((x) => x % 2 == 0).join(':'));
}

Stream<int> countStream(int to) async* {
  for (int i = 1; i <= to; i++) {
      yield i;
    }
 }