take 看下官方文檔

take : 指定 觀察者正序接受指定的items數量

takeLast 指定觀察者正序接受最后指定的items的數量

看下demo

take的代碼

  Observable.just(1,2,3,4,5,6).take(2).subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.e("--------rxjava",integer.toString());}});

指定接受前2個

takeLast 的代碼

   Observable.just(1,2,3,4,5,6).takeLast(2).subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.e("--------rxjava",integer.toString());}});

指定接受最后2個

總結

以上是生活随笔為你收集整理的RxJava 过滤操作符 take 与 takeLast的全部內容，希望文章能夠幫你解決所遇到的問題。

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