Shouldn't this be in `rx.observables` instead of `rx.subjects`?