<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國際加速解決方案。 廣告
                ## TakeLast 發射Observable發射的最后N項數據 ![takeLast](https://box.kancloud.cn/2b1b3e9ef211b05e964b798b800b6a14_1482x550.png) 使用`TakeLast `操作符修改原始Observable,你可以只發射Observable'發射的后N項數據,忽略前面的數據。 ### taskLast.n ![takeLast](https://box.kancloud.cn/2a0b82786cc9521967f9f13bad234603_1280x620.png) 使用`takeLast `操作符,你可以只發射原始Observable發射的后N項數據,忽略之前的數據。注意:這會延遲原始Observable發射的任何數據項,直到它全部完成。 `takeLast `的這個變體默認不在任何特定的調度器上執行。 * Javadoc: [takeLast(int)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeLast(int)) ### takeLast.t ![takeLast](https://box.kancloud.cn/ad2a654ef3545e34d12f47cf8d9231f1_1280x620.png) 還有一個`takeLast `變體接受一個時長而不是數量參數。它會發射在原始Observable的生命周期內最后一段時間內發射的數據。時長和時間單位通過參數指定。 注意:這會延遲原始Observable發射的任何數據項,直到它全部完成。 `takeLast `的這個變體默認在`computation`調度器上執行,但是你可以使用第三個參數指定其它的調度器。 ### takeLastBuffer ![takeLast](https://box.kancloud.cn/9ed37fd4b222fea604de2cc702ca6a03_1280x620.png) 還有一個操作符叫`takeLastBuffer`,它和`takeLast`類似,,唯一的不同是它把所有的數據項收集到一個`List`再發射,而不是依次發射一個。 * Javadoc: [takeLastBuffer(int)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeLastBuffer(int)) * Javadoc: [takeLastBuffer(long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeLastBuffer(long,%20java.util.concurrent.TimeUnit)) * Javadoc: [takeLastBuffer(long,TimeUnit,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeLastBuffer(long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler)) * Javadoc: [takeLastBuffer(int,long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeLastBuffer(int,%20long,%20java.util.concurrent.TimeUnit)) * Javadoc: [takeLastBuffer(int,long,TimeUnit,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeLastBuffer(int,%20long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler))
                  <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>

                              哎呀哎呀视频在线观看