我有以下代码： return getBar(xyz).flatMap(b -> Flux.empty()));
}但它会导致编译错误，因为getBars()返回的是Mono<Bar>而不是Flux<Bar>。如何从Mono值的flatMap()返回Flux？谢谢。
浏览 3提问于2019-11-03得票数 3
回答已采纳
对于他们中的每一个人，我需要发送和接收一些东西： .flatMap(tracker -> 我耍了个丑恶的把戏，但奏效了： .han
浏览 5提问于2018-01-13得票数 13
回答已采纳
我有一个问题，从Flux中减少3000个整数会抛出StackOverflowErrorfor (int i = 0; i < 3000; i++) {} .reduce(
Mono.just(Tupl
浏览 8提问于2021-05-27得票数 0
2回答
使用服务器发送事件获取对这些汇率的实时更新的spring项目
@Autowired private CryptoCurrencyRepository currencyRepository;
.flatMap(rateRepository::findTop
浏览 0提问于2018-11-16得票数 3
回答已采纳
1回答
我现有的代码： return Flux.just(new TestData(1), new TestData::fromIterable);我想丰富现有代码，并在一些不允许接收数据时抛出异常，我做了以下更改：
private Flux<Integer> testGetFluxTestData2(new IllegalTestDataException("illegal test data 1&q
浏览 2提问于2020-10-05得票数 0
回答已采纳
3回答
现在我有这样的事情 service1.getConfig(), //produces flux { LOG.info("flux started");assertResults(
浏览 6提问于2020-01-17得票数 1
回答已采纳
1回答
因此，我想使用Flux来运行每个Mono任务，并将每个任务等待2秒。[Test worker] INFO reactor.Mono.Just.2 - | request(unbounded)Number: 3
01:58:21.479 [Test worker] INFO reactor.Mono.Just.
浏览 6提问于2022-04-27得票数 0
我想确保我的实现是正确的，并且我正确地使用了Flux和Mono来实现CRUD操作。我还希望确保正确地处理任何错误或空值。@Repository}
Flux<Movie
浏览 0提问于2017-03-28得票数 3
回答已采纳
1回答
到目前为止，我只使用了来自WebClient .bodyToMono() steps的WebClient，并且主要是使用这些Mono的或.zip()的多个步骤。如何实现这一目标。
就像在每个服务中异步调用每个searchSingleItem方法一样。
浏览 7提问于2022-10-20得票数 0
回答已采纳
您好，我的代码如下所示： fun mapBatch(batch: List<String>): Mono<List<MyClass>> ...fun myFun(stream: Flux<String>): Flux<MyClass> { .bufferTimeout(50, Duration.ofSeconds60L))
.flatMap{ batch -> mapBatch(batch)
浏览 132提问于2021-06-14得票数 2
回答已采纳
1回答
单螺纹单焊剂
、、、、
我有来自db的Flux<Foo> (例如，5个元素)。我需要从每个Foo获取一些信息，将其全部设置为Mono<MyRequest>，发送到另一个rest资源，获取一个Mono<MyResponse>并在每个Foo中使用其中的所有信息。我在Flux.flatMap()中使用了大量的Mono.zipWith()和Mono.zipWhen()、，但是创建MyRequest和发送到资源的情况由5个线程执行了5次。Fl
浏览 0提问于2018-02-05得票数 3
回答已采纳
1回答
我希望能够测量我的每个k8s吊舱，说我想每秒处理1000条消息，这怎么能在Flux中实现呢？我已经在平面图中尝试过极限率和并发性，但这并没有帮助。Flux.fromIterable(a).limitRate(1000).publishOn(Schedulers.boundedElastic())
.flatMap(localSystem.out.println(System.currentTimeMillis() + ": time for : flatmap "+ local)
浏览 8提问于2022-02-04得票数 1
1回答
问题方法需要等待Mono操作结果，将其用于Flux操作并返回Flux。public Flux<My> getMy() {任务如何等待dateTim
浏览 3提问于2021-10-26得票数 3
回答已采纳
在没有flatMap的订阅服务器中使用demand .doOnRequest(i -> System.out.printlnRequested: " + i)) //.flatMap(Mono
浏览 21提问于2020-05-09得票数 0
回答已采纳
1回答
组合成一组的弹簧反应器组
、、、、
我想知道如何从Flux<Order>获取Mono<Set<Customer>>。我一直在尝试到处阅读，这里是我能找到的最接近的地方，但它仍然不能编译。在以下示例中，orderService.getAll(orderCriteria)返回Flux<Order>
final Mono<Set<Customer>> customerSetMono =
浏览 2提问于2019-10-31得票数 1
回答已采纳
1回答
我试图从I/O中获得一个Flux，当它返回一个对象列表时，以及如何组合从我的服务返回Mono。Flux<Obj1> -> Mono<Obj2>
{"combine" : "456"}
Flux<Obj1>
浏览 1提问于2019-08-25得票数 2
我是Spring中的Project Reactor的新手，我不完全确定如何执行某些操作：我在想：关键是，我不知道该怎么做。
浏览 73提问于2020-05-22得票数 3
回答已采纳
我对反应性的世界非常陌生，并且很难理解如何完成一项任务。我正在处理一个遗留项目，在这个项目中，我必须实现一个接口，该接口有许多方法可以从redis查询各种对象。有时候，查询就像通过ID查询哈希一样简单，因此它只是对redis的一个调用来获取哈希。}
此时，我可以调用mono.block()来获取结果值。在我的原始代码中，我可以重复使用每种方法，并从另一种方法调用，但是我不知道如何用反应堆来实现这一点。我希望能够调用一个方法来构建一个Flux来从redi
浏览 4提问于2017-07-28得票数 3
回答已采纳
我无法将Mono<List<Object>>处理为List<Object>。我在某处读到过可以使用flatmap，但我也不能这样做。我不想在这个场景中使用.block()方法。代码示例可以是：Mono<List<Address>> addressListMono =
Flux.from(s
浏览 5提问于2021-10-31得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
