Support toObservable() on ReadStream()