<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                合規國際互聯網加速 OSASE為企業客戶提供高速穩定SD-WAN國際加速解決方案。 廣告
                # Delay 延遲一段指定的時間再發射來自Observable的發射物 ![delay](https://box.kancloud.cn/2a09cb60b9484884581a9794b8fc249c_1496x562.png) `Delay`操作符讓原始Observable在發射每項數據之前都暫停一段指定的時間段。效果是Observable發射的數據項在時間上向前整體平移了一個增量。 RxJava的實現是 `delay`和`delaySubscription`。 ![delay](https://box.kancloud.cn/46f8abf6d0aaa28c18b7857e646abfa9_1280x620.png) 第一種`delay`接受一個定義時長的參數(包括數量和單位)。每當原始Observable發射一項數據,`delay`就啟動一個定時器,當定時器過了給定的時間段時,`delay`返回的Observable發射相同的數據項。 注意:`delay`不會平移`onError`通知,它會立即將這個通知傳遞給訂閱者,同時丟棄任何待發射的`onNext`通知。然而它會平移一個`onCompleted`通知。 `delay`默認在`computation`調度器上執行,你可以通過參數指定使用其它的調度器。 * Javadoc: [delay(long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#delay(long,%20java.util.concurrent.TimeUnit)) * Javadoc: [delay()](http://reactivex.io/RxJava/javadoc/rx/Observable.html#delay(long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler)) ![delay](https://box.kancloud.cn/ebfe68f5aa4d2149192ac02f991857a6_1280x900.png) 另一種`delay`不實用常數延時參數,它使用一個函數針對原始Observable的每一項數據返回一個Observable,它監視返回的這個Observable,當任何那樣的Observable終止時,`delay`返回的Observable就發射關聯的那項數據。 這種`delay`默認不在任何特定的調度器上執行。 * Javadoc: [delay(Func1)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#delay(rx.functions.Func1)) ![delay](https://box.kancloud.cn/10ab185860c94d9a8d03d964d04e58b1_1280x900.png) 這個版本的`delay`對每一項數據使用一個Observable作為原始Observable的延時定時器。 這種`delay`默認不在任何特定的調度器上執行。 * Javadoc: [delay(Func0,Func1)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#delay(rx.functions.Func0,%20rx.functions.Func1)) ![delay](https://box.kancloud.cn/92a394ad958115ce5c5e646fa1742b54_1280x620.png) 還有一個操作符`delaySubscription`讓你你可以延遲訂閱原始Observable。它結合搜一個定義延時的參數。 `delaySubscription`默認在`computation`調度器上執行,你可以通過參數指定使用其它的調度器。 * Javadoc: [delaySubscription(long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#delaySubscription(long,%20java.util.concurrent.TimeUnit)) * Javadoc: [delaySubscription(long,TimeUnit,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#delaySubscription(long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler)) ![delay](https://box.kancloud.cn/7a1f56b0ccba264aed927414733e213e_1280x620.png) 還有一個版本的`delaySubscription`使用一個Obseable而不是一個固定的時長來設置訂閱延時。 這種`delaySubscription `默認不在任何特定的調度器上執行。 * Javadoc: [delaySubscription(Func0)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#delaySubscription(rx.functions.Func0))
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看