observable-stream

make a stream observable without losing back-pressure control