timeout用于檢測在給定時間內observables沒有及時響應。如果指定的時間量沒有發出任何項目，則超時會使observables失敗并出現TimeoutException。

我們將從debounce的示例中重用我們的observable來演示超時。

輸出：

只要值不超過200ms，就會輸出。一旦值超過到達值，就會推送錯誤。

您可以提供后備observable而不是失敗。發生超時時，生成的observable將切換到備胎。從那時起，原始的可觀察者將被忽略，即使它恢復了。

輸出：

? ?您還可以指定每個項目的超時窗口。在這種情況下，您提供了一個為每個值創建一個observable的函數。當observable終止時，這是超時的信號。如果在此之前沒有發出任何值，則會觸發超時。

以下是使用此重載實現的一個示例：

輸出：

同樣，您可以提供observable的后備。輸出與前兩個示例相同。

原文：https://github.com/Froussios/Intro-To-RxJava/blob/master/Part%203%20-%20Taming%20the%20sequence/5.%20Time-shifted%20sequences.md

下節繼續！

有什么討論的內容，可以加我公眾號：

總結

以上是生活随笔為你收集整理的java自定义一个timeout,Timeout操作符 RxJava 学习笔记二十一的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。