代码之家 › 专栏 › 技术社区 › Johan

通量完成时的返回值?

project-reactor spring-webflux reactive-programming spring-boot

Johan · 技术社区 · 6 年前

我想在 Flux 完成。下面是一个带有(伪)代码的示例,类似于我所追求的:

val myId : Mono<String> = fetchMyId()
myId.flatMap { id ->
     someFlux.map { .. }.doOnNext { ... }.returnOnComplete(Mono.just(id))
}

也就是说,我想回去 id 之后 someFlux 已经完成。这个 returnOnComplete 功能是组成的,不存在(有一个 doOnComplete 功能,但它是副作用),这就是我问这个问题的原因。我该怎么做?

2 回复 | 直到 6 年前

Dimitri Mestdagh 6 年前

你可以使用 then(Mono<V>) 接线员,因为它完全按照你想要的 the documentation :

让这个 Flux 完成,然后播放来自提供的 Mono .

换句话说,忽略这个元素 通量 并将其完成信号转换为所提供的 Mono<V> . 错误信号在结果中重播 单声道; .

例如:

Mono
    .just("abc")
    .flatMap(id -> Flux.range(1, 10)
        .doOnNext(nr -> logger.info("Number: {}", nr))
        .then(Mono.just(id)))
    .subscribe(id -> logger.info("ID: {}", id));

Simon Baslé 6 年前

在顶部 then(Mono<V>) ,如@g00glen00b建议,有一个 thenReturn(V) 当您的延续是一个简单的 Mono.just :

mono.then(Mono.just("foo")); //is the same as:
mono.thenReturn("foo");

推荐文章

ropes-nopes · 如何在反应式Spring集成中处理反应式类型?

3 年前

Bibek Shakya Dev. Joel · Mono<T>和Flux<T>作为函数中的参数

6 年前

Flavouski · 反应性异常处理

6 年前

Viraj · 反应式编程如何实现相关结果

6 年前

Aleksey Kozel · Mono如何订阅

6 年前

KJQ · 如何将2个Spring Mongo反应式保存操作链接在一起?

6 年前

KJQ · 是否可以在底层同时运行Spring WebFlux和MVC(CXF、Shiro等)服务?

6 年前

billdoor · Reactor/WebFlux实现一个反应式http新闻自动收录器

7 年前

Stav Alfi · 了解缓冲区操作的工作原理

7 年前

Ruslan · 无法构造“reactor”的实例。果心出版商Mono ` Spring Cloud OpenFeign和Spring boot 2

7 年前