node-stream-to-observable