streamers 0.0.0

A simple mixin that will allow any class to emit objects via streams. modified from Steven Roose excellent dart-events package.

#Streamers

Streamers provides a simple mixin class, Emitter, to enable any object to emit arbitrary objects through streams. It also provides a convenience mixin class, Receiver, to assist objects in managing their stream subscriptions.

##Example

import 'package:streamers/streamers.dart';

class Foo{}
class Bar{}

void main(){
  var emitter = new Emitter();
  var fooSub = emitter.on(Foo).listen((_) => print('Foo'));
  var barSub = emitter.on(Bar).listen((_) => print('Bar'));
  emitter.emit(new Foo());
  emitter.emit(new Bar());
}

##Example with Receiver

import 'package:streamers/streamers.dart';

class Dog extends Object with Emitter{
  void bark(int volume){
    emit(new Bark(volume));
  }
}

class Cat extends Object with Receiver{
  void dogBarkHandler(Bark bark){
    if(bark.volume > 10){
      print('cat running away');
    }else{
      print('cat not disturbed');
    }
  }
}

class Bark{
  final int volume;
  Bark(this.volume);
}

void main(){
  var dog = new Dog();
  var cat = new Cat();
  cat.listen(dog, Bark, cat.dogBarkHandler);
  dog.bark(9);  // cat not disturbed
  dog.bark(11); // cat running away
  cat.ignoreAll();
  dog.bark(11); // cat isn't listening to anything anymore
}

##All

There is a special Type All which allows receivers to listen for every object emitted by an Emitter with a single handler regardless of the objects type.

/// raw emiiter
emitter.on(All).listen((_) => print('handling all emitted objects'));
/// receiver equivalent
receiver.listen(emitter, All, (_) => print('handling all emitted objects'));