A framework for composing and transforming streams of values