<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>

                ??碼云GVP開源項目 12k star Uniapp+ElementUI 功能強大 支持多語言、二開方便! 廣告
                ## Replay 保證所有的觀察者收到相同的數據序列,即使它們在Observable開始發射數據之后才訂閱 ![replay](https://box.kancloud.cn/b796c9e4925343321c11602f474ec10c_1280x820.png) 可連接的Observable (*connectable Observable*)與普通的Observable差不多,不過它并不會在被訂閱時開始發射數據,而是直到使用了`Connect`操作符時才會開始。用這種方法,你可以在任何時候讓一個Observable開始發射數據。 如果在將一個Observable轉換為可連接的Observable之前對它使用`Replay`操作符,產生的這個可連接Observable將總是發射完整的數據序列給任何未來的觀察者,即使那些觀察者在這個Observable開始給其它觀察者發射數據之后才訂閱。 ![replay](https://box.kancloud.cn/58b1a109d8e0914504050ea6dfead770_1280x1030.png) RxJava的實現為`replay`,它有多個接受不同參數的變體,有的可以指定`replay`的最大緩存數量,有的還可以指定調度器。 * Javadoc: [replay()](http://reactivex.io/RxJava/javadoc/rx/Observable.html#replay()) * Javadoc: [replay(int)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#replay(int)) * Javadoc: [replay(long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#replay(long,%20java.util.concurrent.TimeUnit)) * Javadoc: [replay(int,long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#replay(int,%20long,%20java.util.concurrent.TimeUnit)) ![replay](https://box.kancloud.cn/e03c14dc9ead21b6d3f4550ea5ffce11_1280x900.png) 有一種 `replay`返回一個普通的Observable。它可以接受一個變換函數為參數,這個函數接受原始Observable發射的數據項為參數,返回結果Observable要發射的一項數據。因此,這個操作符其實是`replay`變換之后的數據項。 * Javadoc: [replay(Func1)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#replay(rx.functions.Func1)) * Javadoc: [replay(Func1,int)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#replay(rx.functions.Func1,%20int)) * Javadoc: [replay(Func1,long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#replay(rx.functions.Func1,%20long,%20java.util.concurrent.TimeUnit)) * Javadoc: [replay(Func1,int,long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#replay(rx.functions.Func1,%20int,%20long,%20java.util.concurrent.TimeUnit))
                  <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>

                              哎呀哎呀视频在线观看