first attempt at observableToStream
working example 1