我有返回Mono<Boolean>的函数，并希望将其映射到Mono<Void> (因为这是我在控制器方法中返回的内容)。有没有比返回.flatMap { Mono.empty<Void>() }更好的方法来返回这样的Mono
我无法使用.map{ null }，因为映射函数无法接受null%s。
浏览 57提问于2017-12-24得票数 27
回答已采纳
据我理解，在春季WebFlux反应器中Mono.empty()指的是空，因为调用任何对此的调用都会给出一个空指针。
它们在用法上有何不同？
浏览 8提问于2020-05-15得票数 14
回答已采纳
以下函数： return myService .block();在运行时工作得很好，但在使用WebTestClient测试使用它的流时OnAssemblyException:
Assembly trace from producer [reactor.core.publisher
浏览 13提问于2021-05-14得票数 4
1回答
我使用的是项目反应堆，我想执行以下操作： public void run(ApplicationArguments args) { writeElasticDoc(file.getText()); return Mono.just(message);我很难在项目反应堆中找到与iterateElasticWrites相当的</e
浏览 6提问于2022-04-17得票数 3
回答已采纳
1回答
我是个新手，负责启动网络流量和反应堆，我希望在发生某些特定异常时有一个后备机制，根据我的研究，onErrorResume方法可以做到这一点，但是它不会被调用，我会得到500个内部服务器错误，而不是触发和防止这个错误的回退注:我使用的是弹簧网络流量，这意味着它对反应堆项目的正常行为做了一些改变。public Mono<Date> getExpirationDateFromToken(String token) {
return getAllClaimsFromToken(token).onErrorRes
浏览 4提问于2020-03-22得票数 1
回答已采纳
1回答
(DatabaseSelection.undecided())); .subscriberContext(e
浏览 12提问于2020-10-22得票数 0
3回答
我想在上一次返回Mono<Void>时调用该方法 public Mono<Void> sendEmail(EmailDto emailDto) { ... }
方法sendEmail返回Mono<<em
浏览 5提问于2018-07-25得票数 23
回答已采纳
例如，假设我有一个WebFilter，它编写一些上下文 return chain.filter(exchange)}
下游，我的控制器做这件事我尝试使用RxJava3Adapter.monoToSingle()，但它破坏了<
浏览 4提问于2021-04-02得票数 0
1回答
我编写了一个逻辑，使用spring反应器库获取所有操作符，然后在异步模式下为每个操作符(分页)获取所有设备。 }现在，对于每个操作符，我将获取需要多个订阅才能获得设备MONO的设备，该设备通过订阅mono获得所有页面异步。private void getAndCacheDevicesForOperator(f
浏览 7提问于2022-03-14得票数 4
回答已采纳
我有一个返回Mono<Void>的方法。它还可以返回错误信号。我想要使用then运算符(或任何其他运算符)，仅当前一个操作完成时没有出现错误信号。 Mono.just("GOOD_SIGNAL")//It can also be a BAD_SIGNAL("SOME_SIGNAL");
浏览 0提问于2019-08-29得票数 3
1回答
我有一个基于Spring WebFlux和Reactor的应用程序。应用程序按计划每天启动并加载统计数据。但是也有一个通过控制器的手动启动选项。因此，如果我的应用程序仍在运行，而有人想通过控制器启动应用程序，则可能会发生冲突。这就是为什么我需要一个工具来检测我的反应器链是否还在运行。是否有准备好应用于此任务的工具？有一个简单的boolean复选框解决方案，但是WebFlux/Reactor是否提供了这种功能？反应器链看起来像
浏览 15提问于2020-11-26得票数 0
回答已采纳
1回答
我在Rxjava中有我的代码，我想要更改它的反应器项目。我的rxjava代码是 return data; }
如何使用Flux /
浏览 3提问于2018-06-16得票数 5
我不明白为什么switchIfEmpty调用如果工作的结果hackerService.resetPassword不是空的@PostMapping("/reset/password/{link}ResponseEntity.notFound().build()))服务 BLEExcep
浏览 0提问于2020-10-11得票数 0
回答已采纳
我从reactive仓库得到了一个mono<*>，我想把它的值放到上下文中，但我没有找到正确的接口。kotlin代码：我如何将它的值放到反应器上下文中，如下所示：
userRepository.findById
浏览 0提问于2021-07-02得票数 0
1回答
Monix任务中为空
、、、
项目反应器有一些类似Mono.emptyT的东西，它可以在特殊情况下处理，当你没有任何东西时，它被评估。在Monix Task中有类似的东西吗？def getItemFromList[T](inp: Mono[List[T]]): Mono[T] = { moList.flatMap[T]((list: List[T]) => {
if (list.isEmpty) Mono</
浏览 19提问于2019-03-15得票数 0
我一直在遵循的代码，使用钩子将数据从反应器上下文放入MDC。下面是我使用的小测试。Mono<Integer> integerMono = Mono.just(1)
.doOnEach(logger.addToContext(i -> ImmutableMap.of，在TimeoutMainSubscriber中不调
浏览 19提问于2020-02-18得票数 2
回答已采纳
我的目标是使用超时调用turnOn()，它应该在超时之后调用turnOff()。如果再次调用turnOn()，它应该取消旧的超时并等待新的超时。 我该怎么做呢？我可以做一个hibrate，并使用CompletableFuture的超时，但反应器的应用编程接口只是更容易一点。<Void> turnOn(Duration timeout) {
Mono<Void> turnOnFuture = t
浏览 17提问于2020-10-22得票数 0
回答已采纳
我是项目反应器和网络流量的新手，我想重写我当前的传统的，阻塞的安全过滤器为反应式的，即：@Componentpublic class WhitelistingFilter) { }
protected void<Void> filter
浏览 58提问于2021-12-01得票数 0
我正在开发一个带有spring云的网关，我需要拦截消耗Oauth的请求，然后获得响应并添加带有jwt值的报头(响应为Ouath)。@Autowiredpublic Mono<Void>filter(ServerWebExchange exchange, GatewayFilterChain chain) {
<
浏览 3提问于2021-11-15得票数 1
为了简化我的转换操作，我正在尝试将CompletableFuture包装在一个反应器Mono类型中。一般来说，项目反应器更方便！使用新的AWS Java SDK 2.x版本。这个新的SDK允许对亚马逊网络服务进行异步调用，并返回CompleteableFuture对象。CompletableFuture (s3AsyncClient.getObject)时，执行线程突然切换到CompleteableFuture线程，并且调用Mono的主方法在Compl
浏览 8提问于2019-01-12得票数 1
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
