官术网_书友最值得收藏!

  • Learning RxJava
  • Thomas Nield
  • 168字
  • 2021-07-02 22:22:57

skip()

The skip() operator does the opposite of the take() operator. It will ignore the specified number of emissions and then emit the ones that follow.  If I wanted to skip the first 90 emissions of an Observable, I could use this operator, as shown in the following code snippet:

import io.reactivex.Observable;

public class Launcher {
public static void main(String[] args) {

Observable.range(1,100)
.skip(90)
.subscribe(i -> System.out.println("RECEIVED: " + i));
}
}

The output of the following code snippet is as follows:

RECEIVED: 91
RECEIVED: 92
RECEIVED: 93
RECEIVED: 94
RECEIVED: 95
RECEIVED: 96
RECEIVED: 97
RECEIVED: 98
RECEIVED: 99
RECEIVED: 100

Just like the take() operator, there is also an overload accepting a time duration. There is also a skipLast() operator, which will skip the last specified number of items (or time duration) before the onComplete() event is called. Just keep in mind that the skipLast() operator will queue and delay emissions until it confirms the last emissions in that scope.

主站蜘蛛池模板: 麻阳| 贵溪市| 蒲江县| 洛南县| 涟源市| 巴青县| 栾川县| 通道| 元氏县| 巴东县| 和田市| 达尔| 潜山县| 固阳县| 德兴市| 会理县| 临潭县| 太湖县| 巨野县| 佛学| 民丰县| 桦南县| 波密县| 南投市| 黄山市| 彰武县| 麟游县| 丰镇市| 舞钢市| 土默特左旗| 吴川市| 信阳市| 德清县| 永昌县| 辉县市| 荔浦县| 松滋市| 吉安县| 新巴尔虎右旗| 陆良县| 石渠县|