minor: ObservedSubject.set() -> ObservedSubject.onNext()