A framework for composing and transforming streams of values - View it on GitHub