转载

[Reactor] 操作符实践之skip、take

skip相关方法

skip相关的操作符主要包括skip,skipWhile,skipUntil,skipLast

skip

最简单，顾名思义，跳过前n个元素，如果n超过元素个数，则以元素个数为准

@Test
 public void textSkip() {
     Flux.range(1, 10).skip(3).subscribe(System.out::println);
 }
 
output:
4
5
6
7
8
9
10

skipLast

与skip相反，跳过后n个元素

@Test
    public void textSkip() {
        Flux.range(1, 10).skipLast(3).subscribe(System.out::println);
    }
1
2
3
4
5
6
7

skipWhile

当前n元素都符合predicate的条件，则跳过，直到出现第一个不符合条件的元素

@Test
    public void textSkip() {
        Flux.just(1, 10, 2, 9, 8).skipWhile(n -> n < 7).subscribe(System.out::println);
    }
output
10
2
9
8

skipUntil

当前n元素都不符合predicat的条件，则跳过，直到出现第一个符合条件的元素

@Test
    public void textSkip() {
        Flux.just(10, 1, 2, 9, 8).skipUntil(n -> n < 7).subscribe(System.out::println);
    }
output
1
2
9
8

take相关方法

与skip相对应，take相关的操作符主要包括take,takeWhile,takeUntil,takeLast

take

仅获取前n个元素，如果n超过元素个数，则以元素个数为准

@Test
    public void textTake() {
        Flux.range(1, 10).take(3).subscribe(System.out::println);
    }
output
1
2
3

takeLast

仅获取后n个元素

@Test
    public void textTake() {
        Flux.range(1, 10).takeLast(3).subscribe(System.out::println);
    }
output
8
9
10

takeWhile

仅获取前n元素都符合predicate条件的元素，直到出现第一个不符合条件的元素

@Test
    public void textTake() {
        Flux.range(1, 10).takeWhile(n -> n < 7).subscribe(System.out::println);
    }
output
1
2
3
4
5
6

takeUntil

仅获取前n元素都不符合predicate条件的元素，直到出现第一个符合条件的元素（注意，这个符合要求的元素同样会被获取到）

@Test
    public void textTake() {
        Flux.just(10, 9, 1, 8).takeUntil(n -> n < 7).subscribe(System.out::println);
    }
output
10
9
1

原文 http://www.fullstackyang.com/reactor-skip-take/

正文到此结束

所属分类： Java 编程技术

本文标签： src https CTO ip Reactor UI id cat http
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

[Reactor] 操作符实践之skip、take

skip相关方法

skip

skipLast

skipWhile

skipUntil

take相关方法

take

takeLast

takeWhile

takeUntil

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流