reactive-dart

readme.md

reactive-dart

Created with <3 with dartpad.dev.

main.dart

import 'dart:async';

void main() {
  String chosenCake = 'chocolate';
  // Stream Controller
  final controller = StreamController();

  final order = Order(chosenCake);
  final baker = StreamTransformer.fromHandlers(handleData: (cakeType, sink) {
    if (cakeType == 'chocolate') {
      sink.add(Cake());
    } else {
      sink.addError('Sorry I cannot bake that');
    }
  });

  controller.sink.add(order);
  controller.stream.map((order) => order.type).transform(baker).listen(
      (cake) => print('here is the $cake'),
      onError: (err) => print(err));
}

class Cake {}

class Order {
  String type;
  Order(this.type);
}