RxAndroid Message Queue Timeout

Question

Ich habe Nachrichten eingehende aus Web-Socket. Dazu gehören Zustandsänderungen an einigen Objekten wir diese Zustände A, nennen B, C

Nachrichten: A A B C C A

Ich interessiere mich nur in den letzten Zustand (A) und NUR nach einiger Zeit von keine Aktivität auf ws im Zusammenhang mit dieser Art von Nachrichten. Also, um irgendwie Warteschlange sie, und nach einer gewissen Inaktivität (1000ms) handeln auf dieser letzten (A) Nachricht (jede Nachricht vor dem letzten ist von keinem Interesse). Wie würde ich es mit RxAndroid implementieren? (ich habe Retrolambda bereits verdrahtet und alle Rx bezogen, haben auch ein paar Methoden einige async Sachen Arbeits)

Answer 1

Sie Nachrichten basierend auf ihrem Typ filtern und dann debounce:

Observable<Message> debouncedStream = messageObservable 
.filter(message -> message.getType().equals("A")) 
.debounce(1 , TimeUnit.Seconds); 

Answer 2

i denke, in Ihrem Fall besser .sample() zu verwenden, anstatt .debounce()

Observable<Message> debouncedStream = messageObservable 
    .samlpe(1 , TimeUnit.Seconds); 

sehen Sie den Unterschied sample und debounce