Tag: system.reactive publishsubject

可以用最好的值来观察

我实现了一个名为“FilterByLatestFrom”的伪操作符作为kotlin的扩展函数。 我用这个运算符写下了下面的代码： fun testFilterByLatestFromOperator(){ val observableA : Observable = Observable.fromArray(1,2,3,4,5,6,7,8,9,10) val observableC : PublishSubject = PublishSubject.create() val observableB : Observable = Observable.just(2).mergeWith(observableC) observableB.subscribe { println(“observableB onNext: $it”) } observableA .subscribe({ println(“Original : $it”)}) observableA.filterByLatestFrom(observableB, BiFunction { aVal, bVal -> aVal%bVal==0 }) .subscribe({ println(“Result A : $it”) }) observableC.onNext(3) observableA.filterByLatestFrom(observableB, BiFunction { aVal, bVal -> aVal%bVal==0 […]