腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(654)
视频
沙龙
1
回答
您
应该在
什么时候
阻止
/
订阅
Mono
/
Flux
?
、
、
、
假设你有一些通量和monos val people:
Flux
<Person> = repo.getPeople() val people:
Flux
<People>, val personCount:
Mono
<
浏览 21
提问于2021-08-05
得票数 1
回答已采纳
1
回答
使用spring数据更新对象mongodb和kotlin不起作用
、
、
、
、
我有以下请求处理程序 .flatMap { val oldest = myRepository.findOldest(...) // this is the object I want to modify val v= anotherMongoReactiveRepository.save(Y(...)) // this saves successfully myRepository.save(oldest.c
浏览 0
提问于2018-03-07
得票数 4
回答已采纳
2
回答
在
Flux
<
Flux
<T>>中,如果内部
Flux
<T>最终为空,如何完成外部通量
、
在这些条件下考虑以下代码:
Flux
<
Flux</em
浏览 11
提问于2022-06-16
得票数 0
2
回答
WebFlux -如何检查
Mono
<ResponseEntity<
Flux
<MyItem>>>是否为空以返回404
、
、
我的代码: @PathVariable(value = "email") String> .collectList() //
Mono
<List<U
浏览 7
提问于2020-05-06
得票数 0
回答已采纳
3
回答
订阅
发生在
什么时候
?(春季网通量)
、
、
春季网络流量在
什么时候
进行
订阅
?在我读到的任何地方,都必须有
订阅
,否则就不会发生任何变化。在我使用Spring的短短的时间里,我从未在控制器或服务中见过subscribe()。
订阅
发生在
什么时候
?public
Flux
method(){ ....
浏览 9
提问于2022-01-23
得票数 2
回答已采纳
3
回答
项目反应堆-如何组合
Mono
和
Flux
?
、
、
我有一个
Flux
和
Mono
,我不确定如何组合它们,以便在
Flux
的每一项中都有
mono
值。我正在尝试这种方法,但它不起作用:
Flux
<String>
flux
1 =
Flux
.just("{1}", "{2}", "{3}", "
浏览 20
提问于2018-07-31
得票数 8
回答已采纳
1
回答
等待从下游APIs返回所有
Mono
响应的正确方法是什么?
、
、
、
我对
Mono
和
Flux
很陌生。我正在尝试加入几个下游API响应。这是一个传统的阻塞应用程序。我不想收集
Mono
的列表,我需要从下游API返回的有效负载列表,这是我从
Mono
获取的。我读过几篇的文章 var result = n
浏览 36
提问于2022-06-04
得票数 2
回答已采纳
2
回答
如何让
Mono
等待依赖程序获取方法运行
、
、
我的问题是,调用生成excel文件的函数是在以
Flux
的形式从存储库检索数据之后访问的(没有问题)。<Void> createExcel = excelExport.createDocument(false);
Fl
浏览 0
提问于2019-01-13
得票数 1
回答已采纳
1
回答
在满足条件的情况下如何重复步骤n次
private Boolean compareResults(int prevRes, int nextRes) { } return prevResults.map(elem -> compareResults
浏览 0
提问于2019-01-16
得票数 5
回答已采纳
1
回答
将一个磁通分为单头和尾
、
我想将一个
Flux
分成两个部分:第一个元素(
Mono
)的
Mono
和其他所有东西(尾)的
Flux
。final
Flux
<Integer> baseFlux =
Flux
.range(0, 3).log(); final
Mono
<Integer> head = baseFlux.next().block()).isEqualTo(Arrays.asLi
浏览 2
提问于2020-10-26
得票数 1
1
回答
通量在“那么”之前不会等待元素的完成。
、
、
、
、
我不明白这个问题,我不知道我做错了什么我已经附加了代码片段,doOnNext将填充categoryIdToPrintRepository我已经了解了如何在通量结束后返回
mono
,并在处理onNextSite之前找到了“那时”,但仍在执行“then”方法,这会导致错误: java.lang.IllegalArgumentExceptionpublic
Mono
<ServerResponse> retrieveCatalog(ServerRequest ignore
浏览 5
提问于2020-06-26
得票数 1
回答已采纳
1
回答
项目反应堆中doOnNext的起火和遗忘操作
、
、
、
、
我有一个
Flux
流。对于每个被处理的元素,我希望触发一个异步/非阻塞的操作。例如,从数据库更新返回
Mono
的方法。我希望这个操作在doOnNext块上完成。我不想影响在那里实现的
Flux
、处理和背压。 假设要调用的
Mono
方法是
Mono
<Integer> dbUpdate(); 我的
Flux
应该是这样的吗?public
Flux
<Data> processData(PollRequest request) return s
浏览 33
提问于2021-11-09
得票数 0
回答已采纳
1
回答
如何查看Spring的IntegrationFlow中的流类型
、
、
、
Or
Flux
<Message<?>>?
浏览 4
提问于2022-03-14
得票数 0
回答已采纳
2
回答
与它的计数(或另一个减少功能)连接
、
、
、
、
是否有可能对其进行(Concat)一个具有一些减缩函数的
Flux
,例如传递的元素数?也就是说,例如,将将评估的流量
浏览 6
提问于2020-07-22
得票数 1
回答已采纳
1
回答
使用spring boot项目反应器并行创建多个API调用,但不等待任何其他响应
、
将给定的monos压缩到一个新的
Mono
中,当所有给定的Monos都产生了一个项目时,它将被实现,但我想知道,我将并行调用多个API,但没有任何依赖,我想要一个接一个地公开响应,这在当时是可用的。我已经使用了
Mono
.zip,但它一直在等待所有响应到达。
浏览 25
提问于2021-11-16
得票数 0
1
回答
Springboot webflux reactor从mongoDB删除项目
、
@ApiOperation(value = "Delete multi cities")public
Mono
<ResponseEntity<AtomicInteger>deleteByIds(@RequestBody @NotNull Set<String> ids) {
Flux
.fromIterable}); lo
浏览 19
提问于2021-10-23
得票数 0
回答已采纳
1
回答
项目反应堆-并行执行
、
我有下面的
Flux
, @Test
Flux
<Integer> intFlux =
Flux
.range(1,TODO Auto-generated catch block } } else { return
Mon
浏览 39
提问于2021-08-23
得票数 1
回答已采纳
2
回答
Java中
Mono
<List<Object>>到List<Object>的转换
、
、
、
、
我无法将
Mono
<List<Object>>处理为List<Object>。我在某处读到过可以使用flatmap,但我也不能这样做。我不想在这个场景中使用.block()方法。代码示例可以是:
Mono
<List<Address>> addressListMono =
Flux
.from(s
浏览 5
提问于2021-10-31
得票数 0
1
回答
如何使用
Mono
列表来处理输入
、
、
我有一个输入值,需要传递一个
Mono
链来处理它。下一个输入是前一个结果的依赖项。String originStr = "hello"; for (String rule : rules) {
浏览 4
提问于2022-10-19
得票数 0
1
回答
如何找到一个
Flux
中所有的数据都被处理了,这些数据都是嵌套的
Mono
(非阻塞)?
、
、
假设我嵌套了下面的
Flux
和
Mono
。我有两个不同的Apache Cassandra表的信息。我想合并细节并发送回作为
Flux
。@Autowired TopicRepository topicRepository; public
Flux
<FullDetails> getData(){ return
Flux
.create(
浏览 142
提问于2018-08-02
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring WebFlux和Spring Cloud进行响应式微服务开发
聊聊Spring Reactor反应式编程
Spring Boot 2.0的新特性解读
5个当今仍然有效的离线求职工具
比特情报局—1.19行情分析
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券