如何链接Flux和Mono Publisher？ 我想把它们都链接起来，然后发送响应。基本上，所有操作都是异步执行的。在这里，我使用zip for Mono & Flux来执行所有Mono和Flux发布器。List> monoPubs = new ArrayList<>();
List> fluxPubs
浏览 117提问于2021-02-28得票数 2
回答已采纳
我想知道，用一个参数创建的MonoJust和FluxJust在行为/保证上有什么不同吗？这两者之间唯一的区别是，ScalarSubscription在每次方法调用时都会定义和检查这个volatile int once (计数器)，并在某种程度上确保onComplete()只被调用一次。同时，WeakScalarSubscription将boolean terminado thing (非易失性标志)用于相同的目的，但没有onComplete()调用的“只有一次”保证。在Java语言中使用volatile是有代价的，例如，当一个人在
浏览 9提问于2020-07-05得票数 0
1回答
问题方法需要等待Mono操作结果，将其用于Flux操作并返回Flux。public Flux<My> getMy() { collectionName);
}
RESEARCH
浏览 3提问于2021-10-26得票数 3
回答已采纳
我不明白thenEmpty、thenMany和flatMapMany在Flux上的用法和区别，或者spring webflux中的Mono。
浏览 0提问于2018-01-15得票数 25
回答已采纳
1回答
我需要结合两个反应出版商的结果- Mono和Flux。我试图用zip和join函数来实现它，但是我无法满足两个具体条件：
join)when 结果应该包含与发出的元素一样多的元素，但是相应的Mono源应该只调用一次(这个条件可以单独用实现为空，那么链应该完成而不需要等待Mono元素。)Flux<Integer> flux = Flux.concat(Mono.just(
浏览 10提问于2020-05-11得票数 0
当使用带有Mono或Flux返回类型的Spring webflux时，http连接线程会在连接等待响应时停止/释放。因此，该连接不采用max-connections。问:我如何在等待响应的同时测试/证明连接确实被释放，而不会阻塞最大连接数？public class MyServlet { pub
浏览 0提问于2019-08-01得票数 0
1回答
因此，我的目标是使用WebClient发出多个并发请求，等待它们全部完成，然后组合结果。这是我到目前为止所知道的： ...Flux<ServerResponse> feedResponses = request .mapReturns a list of RSS feed URLs
.map(this::getServerResponsesFromUrls) // Ret
浏览 85提问于2019-05-01得票数 3
回答已采纳
1回答
我有这样的代码： List<Mono> monoList = foo();try { .block();
log.warn("error", e);
} 当所有的MONO都成功完成时，它工作得很完美，但如果至少有一个Mono完成</em
浏览 32提问于2019-12-13得票数 0
1回答
例如，我有一个Flux<Dog>和方法setAge和setName，它们做一些计算，并将数据设置为Dog中的年龄和名称字段。这些方法是独立的，我希望它们同时执行。Flux.fromIterable(mapToResult()) .runOn(Schedulers.parallel())注意:在setAge内部，我有高值的Thread
浏览 8提问于2022-10-16得票数 1
回答已采纳
假设我们有一个返回多个对象的Finder return carRepository.findAll()因为我们想同时将一些逻辑应用于所有的汽车和乘客，所以我们通过.collectList()将其转换为Monoval passengerMono =carsFinder.findAll().collectList()
浏览 2提问于2022-04-28得票数 0
3回答
我想要处理Flux来限制Mono列表所发出的并发HTTP请求。一个请求返回一个列表，并根据结果触发另一个请求。public Flux<JsonNode> syncData() { .getData(param1) List<Mono&l
浏览 12提问于2021-08-20得票数 4
回答已采纳
样本代码： .publishOn(Schedulers.single()) .block();
这将产生以下输出：After为什么它不等待两个出版商(fluxA<em
浏览 0提问于2019-07-12得票数 0
回答已采纳
3回答
如何并行进行多个调用并等待结果？
、、、、
我有两个函数，一个返回一个Flux，另一个返回一个Mono，根据这个Mono的结果，我对发出的Flux条目做了一个非常简单的过滤逻辑。我试着使用zipWith，但是不管是什么过滤逻辑，只有一项完成了它。viewTaskOffers( @AuthenticationPrincipal user: UserPrincipal }.
浏览 2提问于2019-06-05得票数 3
回答已采纳
我有一个聚合工具类，其中我必须连接多个cassandra表数据。我的生产代码如下所示，但不完全相同。我已经尝试了doOnComplete和doOnFinally的外部通量，它不是等待所有内部非阻塞调用完成。我想在处理了onComplete内部所有嵌套的Mono/ Flux (非阻塞)请求之后，调用它。
对于嵌套阻塞通量/单通量，外部通量doOnComplete方法在内部通量/单通量完成后执行。因为doOnComplete()方法是在
浏览 0提问于2018-08-16得票数 1
回答已采纳
我有一个项目反应堆链，其中包括一个阻塞任务(一个网络呼叫，我们需要等待响应)。我想同时运行多个阻塞任务。似乎可以使用ParallelFlux或flatMap()这两个简单的例子： .repeat(10) .runOn(Schedulers.elastic()) .sequential()或
Flux.just(1
浏览 4提问于2017-04-07得票数 25
回答已采纳
我尝试了dispatchOn和publishOn的各种方法，但都不起作用，最终我选择了map(CompletableFuture.supplyAsync(..), executor)，它将flux转换为现在，我希望仅在最后一项完成时才继续流程。我尝试使用all(..)和take(size of the Iterable)，但在这两种情况下，流程都会在所有元素完成之前继续。我假设这是因为我的executor只有4个线程，而将CompletableFuture-s添加到flux中需要一些时间
浏览 1提问于2016-03-23得票数 0
我对Mono和Flux很陌生。我正在尝试加入几个下游API响应。这是一个传统的阻塞应用程序。我不想收集Mono的列表，我需要从下游API返回的有效负载列表，这是我从Mono获取的。如果这是绑定到HTTP请求，则基本上是在触发反应性管道，而不保证资源或完成。调用订阅会触发管道，但不会等到管道完成后再调用
var result = new ArrayList<List<>>(
浏览 36提问于2022-06-04得票数 2
回答已采纳
1回答
我正在学习反应性编程和spring，但我不知道如何返回依赖于Mono分辨率的Flux。interface FooRepository : ReactiveMongoRepository<Foo,String> { .cast(User::class.java)
浏览 3提问于2020-01-08得票数 0
回答已采纳
somethings$ betterThings$, )我已经从上面的文章中复制和粘贴了相关的样本假设something$、betterThings$和defaultThings$是我们的monos isSomething & isBetterThings是谓词。ServerRequest serverRequest) {
浏览 1提问于2019-08-26得票数 1
我有一个发出API调用的服务和另一个返回值流的服务。我需要根据API调用返回的值修改每个值。return Flux.zip( someFlux.Get(),(d, t) -> {
//HERE D IS ALWAYS THE SAME AND T IS EVERY NEW FLUX VALUE}); 我尝试过对Mono使用.repea
浏览 24提问于2020-01-15得票数 2
云服务器
ICP备案
腾讯会议
实时音视频
对象存储
腾讯云开发者
