RxAndroidメッセージキューのタイムアウト

Webソケットからメッセージが届いています。 B C C 私は最後の状態に興味を持っていますRxAndroidメッセージキューのタイムアウト

（：彼らはいくつかのオブジェクトの状態変化がのは、これらの状態A、B、C

がメッセージに名前を付けましょう含ま）このタイプのメッセージに関連するwsのアクティビティがありません。だから、どういうわけかキューに入れて、ある程度の非アクティブ（1000ms）後には、最後の（A）メッセージの最後のメッセージはとなります。 RxAndroidを使用してどのように実装しますか？（私はすでにRetrolambdaを有線およびすべてのRxに関連している、また、いくつかの非同期のものを作業方法のカップルを持っている）

出典

2016-11-23 miroslavign

メッセージAの観測可能性について 'debounce（）'を試してみてください。 http://reactivex.io/documentation/operators/debounce.html – vkislicins

オペレータ用のTnxですが、少しのコードが助けてくれます。 – miroslavign

すごく慌てていて、何かをすばやく参照して助けたいと思って申し訳ありませんあなたを助けるかもしれない。役に立たなかった場合はお詫び申し上げます。 – vkislicins

あなたは自分のタイプして、デバウンスに基づいてメッセージをフィルタリングすることができます

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

出典

2016-11-23 19:09:19

実際に私はそれらをフィルタリングしたくない、私はこのrxのものに行く前にそれらを事前にフィルタリングします。私はちょうど新しいメッセージが到着した後に最後のものを使いたいです。 – miroslavign

私は違いを参照してください。代わりに.debounce()

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

の.sample()を使用することをお勧めし、あなたのケースで推測sampleとdebounce

出典

2016-11-23 20:27:23

RxAndroidメッセージキューのタイムアウト

答えて

関連する問題