RxJava操作符实践：3_过滤操作之2_takeLast

一、描述

发射Observable发射的最后N项数据。

使用TakeLast操作符修改原始Observable，你可以只发射Observable发射的后N项数据，忽略前面的数据。

使用takeLast操作符，你可以只发射原始Observable发射的后N项数据，忽略之前的数据。注意：这会延迟原始Observable发射的任何数据项，直到它全部完成。

takeLast的这个变体默认不在任何特定的调度器上执行。

二、示意图

三、示例代码

Observable.just(1, 2, 3, 4, 5, 6)
    .takeLast(3)
    .subscribe(new Subscriber<Integer>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(Integer integer) {
            System.out.println("onNext: " + integer);
        }
    });

四、运行结果

onNext: 4
onNext: 5
onNext: 6
onCompleted.

项目代码已上传到Github：https://github.com/SherlockShi/RxJavaBestPractise

五、更多

本操作符还有以下变体：

• takeLast(int, long, TimeUnit)

相关的操作符还有：

• takeLastBuffer

详情可查阅下面的参考资料。

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客