streams

readme.md

streams

Created with <3 with dartpad.dev.

main.dart

import 'dart:async';
void main() {
  final controller = StreamController();
  final order = Order('chocolate');
  
  final baker = StreamTransformer.fromHandlers(
    handleData:(cakeType,sink){
      if(cakeType == 'chocolate'){
        sink.add(Cake());
      }else {
        sink.addError('I can\'t process this type');
      }
    }
  );
  controller.sink.add(order);
  controller.stream.map(
    (order) => order.type
  ).transform(baker)
    .listen(
    (cake) => print('Here is your cake, $cake'),
    onError:(err) => print(err)
  );
  
}

class Cake{}
class Order{
  String type = '';
  Order(this.type);
}