Composing and transforming Reactive Streams