RxJava 2：Observable.create（）は、非同期コードがThread.sleep（）を使用して終了するまで待機します。

Question

Observable.create(...)を使用して非同期コードをラップしています。非同期コードは5秒間 "アクティブ"にする必要があり、その後停止する必要があります。

Observable.<MyObject>create(emitter -> { 

    // Some async code 

    emitter.setDisposable(Disposables.fromRunnable(() -> { 
     // Stop the above async code 
    })); 

    // Wait for 5 seconds until the async code above has had enough time to finish its task. 
    Thread.sleep(5000); 

    if (!emitter.isDisposed()) { 
     // Stop the above async code 
     emitter.setDisposable(null); 
    } 
})... 

私はThread.sleep(5000)が使用されているので、これが最善の方法であるのかはわからない：これは、私は現在、それを停止しています方法です。いくつかのRxJavaコードでこれを行うより良い方法はありますか？

Observable.<MyObject>create(emitter -> { 

    // Some async code 

    emitter.setDisposable(Disposables.fromRunnable(() -> { 
     // Stop the above async code 
    })); 
}) 
.take(5, TimeUnit.SECONDS); 

あなたはまだcreateにセットアップDisposableにあります

Answer 1

を使用すると、指定した時間が経過するまでのソースからアイテムを持つことができますtakeの時限式過負荷が存在します。