Change Composable Spec to accept observable,
add Streams.on