Rx Android: Entprellen Anrufe zu berechnen und zurückgeben letzten berechneten Wert

Question

Ich bin neu in Rx Android. Ich sehe Betreiber wie Drossel & debounce; Ich bin jedoch nicht in der Lage, herauszufinden, wie ich es in meinem Szenario effektiv einsetzen kann.

In meiner APP aus mehreren Threads der Ausführung einige globalen Zustand zu aktualisieren und fordert eine teure Berechnung durchzuführen. Die Berechnung muss an einem anderen Thread durchgeführt werden. Anruferthread empfängt das Berechnungsergebnis mit Observable.

Es kann mehrere aufeinander folgende oder parallele Aufrufe zur Berechnung geben. Ich möchte die Aufrufe zu bestimmter Zeitdauer entprellen und alle Anrufer sollten den letzten berechneten Wert erhalten.

Für z. Wenn drei Threads T1, T2 & T3 eine Berechnung innerhalb eines Zeitraums von 500 ms anfordern, muss die Berechnung nur einmal durchgeführt werden. Alle Threads T1, T2 & T3 Beobachtung für das Rechenergebnis (Observer) erhält das letzte berechnete Ergebnis.

Answer 1

So ähnlich?

BehaviorSubject<Object> b = new BehaviorSubject(); 
Observable<T> computationChain = 
     b 
     .onSubscribe(() -> b.onNext(null)) 
     .debounce(500, TimeUnit.MILLISECONDS) 
     .observeOn(Schedulers.computation()) 
     .map(dummy -> performExpensiveComputation()) 
     .share(); 

.... 

public Observable<T> getComputation() { 
    return computationChain; 
} 

.... 

getComputationChain().subscribe(value -> doSomething(value)); 

Edit: vielleicht wird dies besser funktionieren:

BehaviorSubject<Object> b = new BehaviorSubject(); 
Observable<T> computationChain = 
     b 
     .debounce(500, TimeUnit.MILLISECONDS) 
     .observeOn(Schedulers.computation()) 
     .map(dummy -> performExpensiveComputation()) 
     .publish(); 
     .onSubscribe(() -> b.onNext(null))