Reactor系列(十一)take获取

2020-08-04T22:23:28
关注公众号【好便宜】( ID:haopianyi222 ),领红包啦~
阿里云,国内最大的云服务商,注册就送数千元优惠券:https://t.cn/AiQe5A0g
腾讯云,良心云,价格优惠: https://t.cn/AieHwwKl
搬瓦工,CN2 GIA 优质线路,搭梯子、海外建站推荐: https://t.cn/AieHwfX9

java#reactor#take#获取

获取Flux订阅数量

视频讲解:https://www.bilibili.com/video/av80322616/

FluxMonoTestCase.java

package com.example.reactor;

import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;

import java.time.Duration;

@Slf4j
public class FluxMonoTestCase extends BaseTestCase {
    @Test
    public void take(){
        //根据数量获取
        Flux.range(1,10).take(0).log().subscribe(System.out::println);
        //根据实际获取
        Flux.range(1,10000).take(Duration.ofMillis(2)).log().subscribe(System.out::println);
        //根据条件获取
        Flux.range(1,10).takeUntil(item ->item == 5).log().subscribe(System.out::println);
    }
}

关注公众号,坚持每天3分钟视频学习

扫一扫关注公众号添加购物返利助手,领红包
当前页面是本站的「Baidu MIP」版。发表评论请点击:完整版 »
因本文不是用Markdown格式的编辑器书写的,转换的页面可能不符合MIP标准。