I think RxJs[1] can help here as well.

[1]: https://github.com/Reactive-Extensions/RxJS