RxJava：サンプリングする方法を変更しないで繰り返す

Question

Observable tが刻々と変化するたびにObservable xの最新の、場合によっては繰り返される（！）値を常に出力するObservableを構築したいと思います。 tの間に変更がなければ、xの繰り返し値を出力しないので、x.sample(t)を使用することはできません。

Answer 1

私の解決策です。 Pairはleftとright値を持つ単純なJava Beanです

public <T, F> Observable<T> answer(Observable<T> values, Observable<F> trigger) { 
    return Observable.combineLatest(values, trigger, Pair::of) 
     .distinctUntilChanged(p -> p.getRight()) 
     .map(Pair::getLeft); 
    } 

。