Reactive stream combinators in Haskell! Implementations of Rx primitives based on the 'machines' library - View it on GitHub