腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
从一
个
flux
中
准确
地
获得
n
个
成功
的
操作
结果
?
java
、
project-reactor
有一
个
通量发出
的
m元素,然后我想一
个
接一
个
地
对每个元素做一
个
操作
,返回一
个
单声道,并得到
n
成功
的
操作
结果
。当我得到
n
成功
的
结果
时,我想停止流。List<Integer> items = new ArrayList<>(); AtomicLong counter = ne
浏览 163
提问于2021-10-14
得票数 0
1
回答
试图管理多个
Flux
/Mono,先启动其中
的
几个,然后将其中
的
一些组合起来,然后有点丢失。
project-reactor
、
reactor
、
spring-data-mongodb-reactive
考虑到这一点,我怎么能:
Flux
.empty())Add 为解决所有问题所需
的
每个
操作
创建一
个
"holder“或一
个
”容器“,并将它们初始化为空(就像上面第1项
中
我可以创建
的
任何项) --它被初始化为空,但我可能希望
从一
个
或多个有限和异步
的
Flux
操作
中
获得
数据,但我不想让它们分开,当我将在它们上使用collectList()生成一<
浏览 4
提问于2020-12-30
得票数 0
回答已采纳
1
回答
重试下一
个
Flux
元素,忽略
成功
的
那个
spring
、
reactive-programming
、
spring-webflux
、
project-reactor
诀窍是,在连接失败或
Flux
元素失败
的
情况下,我想在
Flux
上重试几次,但是一旦能够掌握它,我希望
从一
开始就不处理这些元素。我
的
意思是,有些地方出了问题,因为连接失败,我只从我
的
Flux
中
得到了56
个
元素(假设它是.jpg
中
的
一
个
映像)。一旦我
成功
地
重试,我想继续使用57元素,这样我就不必
从一
开始就处理它并执行GET。下面是正常
浏览 1
提问于2019-10-10
得票数 1
回答已采纳
1
回答
Java Reactor:有没有一种方法可以在不急切获取
的
情况下将
Flux
<Mono<T>>转换为
Flux
<T>?
java
、
reactive-programming
、
project-reactor
、
spring-webclient
我有一
个
快速但昂贵
的
生产者(Spring WebClient)和一
个
非常慢
的
订阅者。我需要一种方法来尊重整个链条
的
背压。在实现过程
中
,我意识到flatMap、concatMap和其他公司都在使用急切抓取,而且似乎不可能禁用这种行为。在没有flatMap
的
订阅服务器中使用demand .doOnRequest(i -> Sys
浏览 21
提问于2020-05-09
得票数 0
回答已采纳
2
回答
反应器从
Flux
<String>
中
过滤出List<String>
java
、
spring-webflux
、
project-reactor
假设我们有有办法过滤掉列表
中
的
通量吗?换句话说,从列表
中
减去流量,
结果
应该是"C", "D"。 纵观反应堆
的
文档,filterWhen似乎是最近
的</
浏览 2
提问于2021-08-23
得票数 1
回答已采纳
1
回答
如何
将两
个
Flux
<>对象组合为一
个
java
、
project-reactor
从一
开始,我对反应性编程就有点陌生了。在参加了一些关于反应堆和Spring5.0
的
讲座之后,我想自己尝试一下这个编程模型。我有一
个
应用程序,它使用WebClient从不同
的
API构建两
个
Flux
对象。我想将这两
个
对象组合成一
个
,并将其返回给用户。class CompleteUser { private String address; //getters and sette
浏览 3
提问于2017-05-31
得票数 1
回答已采纳
1
回答
合并通量
结果
和返回通量
java
、
spring-boot
、
spring-webflux
、
project-reactor
我有一
个
List<Event>,对于每个Event,我需要设置EventDocument。我
从一
个
api
中
获取
Flux
<EventDocument>。我需要将正确
的
EventDocument映射到Event并返回
Flux
<Event>。获取EventDocument
的
接口调用 private
Flux
<EventDocument> getDocuments(List<Long>
浏览 14
提问于2021-05-09
得票数 0
回答已采纳
2
回答
反应堆
中
的
map与flatMap
java
、
project-reactor
我已经找到了很多关于
的
答案,但我想了解它在Reactor
中
是
如何
工作
的
。files.flatMap { it -> } .f
浏览 1
提问于2018-03-06
得票数 45
回答已采纳
1
回答
为什么一些反应堆
操作
人员要求
的
元素比他们感兴趣
的
要多得多?
java
、
project-reactor
、
reactive-streams
<String>never()它是一
个
从不发出任何信号
的
Flux
,但它向控制台报告需求但是,
Flux
#blockFirst()、
Flux
#next()和Mono#block()各自需要从其上游
的
最大一
个
元素,而
Flux
#take()则需要最大限度<e
浏览 1
提问于2021-03-02
得票数 2
回答已采纳
1
回答
如何
在一
个
Flux
中
获取未出现在另一
个
Flux
中
的
元素
spring-webflux
、
reactive
我有两
个
Flux
,一
个
有更多
的
元素,比如
Flux
<Integer> bigFlux =
Flux
.range(1, 10); 和另一
个
喜欢
Flux
<Integer> smallFlux =
Flux
.just(3, 7);
如何
获取bigFlux
中
没有出现在smallFlux
中
的
元素?a)); 但这并不明智,我是通过复杂
的</e
浏览 25
提问于2019-08-31
得票数 0
1
回答
Java
中
的
Mono类:什么是,什么时候使用?
java
、
spring
、
spring-boot
、
project-reactor
、
spring-mono
;} 我理解这段代码,除了Mono类做什么以及它
的
特性是什么。我做了很多搜索,但没有直接说到重点:,Mono,和类是什么,什么时候使用
浏览 9
提问于2020-03-16
得票数 45
1
回答
如何
在
Flux
<String>控制器
中
从SpringBoot获取JSON格式?
json
、
spring-boot
、
project-reactor
、
restful-url
我使用项目反应堆来建立一
个
反应堆SpringBoot演示,我已经完成了很多功能,并
成功
地
在我
的
演示
中
获得
/发布。现在我遇到了一
个
问题,从Controller返回
的
结果
不是JSON格式,而是像这样
的
连接字符串:"reactortestPostTitleReactorProgramming Reactor 3.xtestbypostman"]我在实体包
浏览 5
提问于2020-07-29
得票数 1
回答已采纳
1
回答
我
如何
从
Flux
中
的
组件
中
检测和响应
成功
和失败?
reactjs
、
react-router
、
flux
单击"create“按钮将调用一
个
将数据发送到API
的
操作
。如果资源已
成功
创建,则分派一
个
“
成功
”
操作
。否则,发出“失败”
操作
。 组件
如何
对
Flux
中
的
成功
或失败作出响应?我应该在存储区
中
设置一
个
由组件读取
的
成功
/失败标志吗?我是否应该在组件上使用自己
的
侦
浏览 2
提问于2017-05-04
得票数 2
回答已采纳
2
回答
如何
将字符串变量
中
的
“不可见”转义字符转换为另一
个
变量
string
、
swift
、
escaping
在Swift
中
,我可以创建一
个
字符串变量,如下所示:如果我使用s,输出将是:My name is Jack!(因为\
n
是一
个
行提要)let sRaw = s.rawHello\nMy na
浏览 3
提问于2016-06-07
得票数 0
回答已采纳
1
回答
为什么这个IO处理不起作用(IO (a,b))
haskell
我试图从IO类型
的
表达式(或者是b)中提取"a“和错误"b”。这就是我试图提取a和b值
的
方式:rFile f = dol <- readFile' f Right
n
浏览 3
提问于2022-03-09
得票数 1
2
回答
反应堆
的
通流通风机抽出来了吗?
java
、
functional-programming
、
project-reactor
我试图在
Flux
/Publisher上执行以下
操作
,这些
操作
只能读取一次(考虑数据库
结果
,可以读取一次)。但是,这个问题具有足够
的
通用性,可以在没有反应堆知识
的
情况下在函数式编程环境
中
回答。distinctAndHasElement(4,
Flux
.just(1,2,3,3,4,4,5)); Mono<Pair<Long, Boolean>> distinctAndHasElement(int toCheck, <
浏览 9
提问于2021-06-08
得票数 1
回答已采纳
1
回答
Java异常处理?
java
、
stream
、
flux
、
parallelstream
有人能指导我,因为我是新
的
变化,并试图了解
如何
处理这一情况?r
浏览 9
提问于2022-04-05
得票数 0
2
回答
如何
筛选出不包含
Flux
<String>值
的
Flux
<String>
project-reactor
假设我有一
个
包含
Flux
<String> firstLetters
的
"A", "B", "C", "D"和包含"X", "Y", "Z"
的
Flux
<String> lastLettersdata class Example(val name: String) 从整个
Flux
<
浏览 2
提问于2019-08-06
得票数 1
回答已采纳
2
回答
始终以prolog显示
的
"display“
prolog
我有一
个
谓词check(Data,Res),它根据一些规则检查Dats并返回Res ( Data上
的
一
个
函数
结果
,假设Data满足几个条件)。我有另一
个
生成
N
-size Data
的
函数generate(
N
,Data)。我
的
主程序从生成多个1-size Data开始,如果没有一
个
满足条件,则继续执行2-size Data,依此类推,直到达到某个M上限。main(M):- next_number(
N
,M
浏览 0
提问于2020-09-08
得票数 1
1
回答
Flux
.compose与
Flux
.transform
的
差异?
reactive-programming
、
publish-subscribe
、
project-reactor
、
publisher
、
reactive-streams
我正在学习reactive和Publisher(
Flux
),并致力于
Flux
的
转换。为此,我得到了合成和转换方法。这是我
的
代码: System.out.println("*********Calling composeStream************"); Function<
Flux
<String>,
Flux
<String>> al
浏览 5
提问于2018-01-03
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Julia 机器学习框架入门实战
我用80行 Haskell 代码构击败了 C 语言
Reactive Spring实战 -- 理解Reactor的设计与实现
Spring Boot 中的响应式编程和 WebFlux 入门
Spring Boot WebFlux框架响应式编程数据实时更新
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券