Broadcast Stream example in Dart

stream_2.dart

import 'dart:async';

void main() {
  //
  // Initialize a "Broadcast" Stream controller of integers
  //
  final StreamController<int> ctrl = StreamController<int>.broadcast();
  
  //
  // Initialize a single listener which filters out the off numbers and
  // only prints the even numbers
  
  final StreamSubscription subscription = ctrl.stream.where((value) => (value % 2 == 0)).listen((value) => print('Divisible by 2 : $value'));
  
  final StreamSubscription subodd = ctrl.stream.where((value) => (value % 3 == 0)).listen((value) => print('Divisible by 3 : $value'));

  //
  // We here add the data that will flow inside the stream
  //
  for(int i = 1; i < 100; i++){
    ctrl.sink.add(i);
  }
  //
  // We release the StreamController
  //
  ctrl.close();
}