2回答
public Mono<OrderDTO> addProductsToOrder(String orderId, String[] productIds)
final Fl
浏览 16提问于2018-08-14得票数 1
回答已采纳
1回答
我需要结合两个反应出版商的结果- Mono和Flux。我试图用zip和join函数来实现它，但是我无法满足两个具体条件：
join)when 结果应该包含与发出的元素一样多的元素，但是相应的Mono源应该只调用一次(这个条件可以单独用实现为空，那么链应该完成而不需要等待Mono元素。)Flux<Integer> flux = Flux.concat(Mono.just(1).delayE
浏览 10提问于2020-05-11得票数 0
我有一个发出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
我的REST控制器方法应该返回Mono，它必须由2个并行请求构建到另一个web服务，并处理它们的响应，其中一个请求返回Mono，另一个请求返回Flux。 studentIds.add(studentId);控制器：
浏览 0提问于2019-08-29得票数 0
回答已采纳
5回答
我开始使用项目反应堆，而我很少挣扎的地方之一是如何将来自Mono和Flux的东西结合起来。interface UserRepository {}
Mono<GroupModel> groupMono有人能帮忙如何组合来自userFlux和groupMono的结果吗？我想我使用类似Zip的东西，但是它会从源到源进行一到一映射。在我的例
浏览 6提问于2017-04-19得票数 8
回答已采纳
我对反应性流很陌生，我学习使用concat/串联using方法将两个发布者(Flux是特定的)结合在一起。 Mono<String> mono1 = Mono.just(" karan ");
Mono<String> mono2 = Mono.just(&qu
浏览 2提问于2018-01-02得票数 2
回答已采纳
1回答
import org.springframework.web.reactive.function.server.ServerResponse;public class GreetingHandler }我理解这段代码，除了Mono类做什么以及它的特性是什么。我做了很多搜索，但没有直接说到重点：，<
浏览 9提问于2020-03-16得票数 45
我在Webflux控制器中使用Monos和ResponseEntitys，以便操作报头和其他响应信息。例如：fun getOneUser(@PathVariable userId: UserId): Mono<ResponseEntity<UserDto结合使用。使用ResponseEntity<Flux<T>>是正确的吗？}
我想在这里实现的行为是，如果repository.findBy
浏览 0提问于2018-09-25得票数 9
回答已采纳
然后我把它叫做用Flux做处理器。public Flux<Product> getRecommend(Long userId) throws InterruptedException, ExecutionException, TimeoutExceptionwrapper.getRecommend(userId).get(2, TimeUnit.SECONDS);
return Flux.fromIterable(recommendList)
浏览 3提问于2020-08-24得票数 6
回答已采纳
我有一个尝试使用WebClient返回Mono的方法 public Mono<Object> getMatch(@RequestParam@GetMapping("getMatches")
public Flux<Object> getMatches(@RequestParam String matchesId) {List<Long> matchesList = JSON.parseArray
浏览 3提问于2019-09-29得票数 4
回答已采纳
2回答
将所有元素组合为单声道的通量
、、、、
Flux<String> fluxString = Flux.just("A","B","C");预期结果是这样的Mono<String> expectedresult = "Original A B C";
方法1 ->我可以等待通量的所有元素被接收，然后将它们与单
浏览 11提问于2021-04-10得票数 0
我创建了这样一个WebSocketHandler实现：public Mono<Void> handle(WebSocketSession session) {
var publisher = flux.map( o -> {
浏览 0提问于2019-03-06得票数 3
回答已采纳
我做了一个get调用，响应被映射到Mono，使用body将对象列表映射到mono。现在我想为这个object.How返回一个Flux类型，我是否可以实现这一点来转换Mono<List<MyObject>> to Flux<MyObject>
浏览 0提问于2018-06-19得票数 0
3回答
我想要创建一个服务，它结合了两个反应源的结果。一种是生产Mono，另一种是生产通量。对于合并，对于发出的每个通量，我都需要相同的mono值。现在我有这样的事情 service1.getConfig(), //produces flux {
final Flux</em
浏览 6提问于2020-01-17得票数 1
回答已采纳
1回答
); // Replacing actual API call here} 现在，我有了另一个方法，它应该结合这两个方法的结果，并在checkFirstExists或checkSecondExists为真时简单地返回一个布尔值。boolean checkIfExists() {
// Should return true
浏览 71提问于2020-09-26得票数 2
我正在学习Spring，在编写示例应用程序的过程中，我发现了与Spring WebFlux结合使用的反应式类型(Mono/Flux)相关的一个问题。TaskService(val taskRepository: TaskRepository) {
fun get(id: String): Mono<Task> = taskRepository.findById(id)这种缓存返回Mono或Fl
浏览 4提问于2018-01-09得票数 25
回答已采纳
我想要创建一个带有端点的微服务A，它接受一个数字N，向microservice B发送N个请求(它为每个请求返回一个字符串)，将字符串包装成对象，将它们组合成一个List/Flux (?)a value received from B} private int number;
浏览 1提问于2021-05-01得票数 2
回答已采纳
例如，在我的例子中，我有这个类扩展：
fun <T> Flux<T>.toServiceResponse(): Mono<Response<("The \"
浏览 4提问于2022-02-12得票数 0
回答已采纳
1回答
我有一个通量和Mono，如下所示：Mono<List<String>> mono1= req.map(r -> r.getList());;
Flux<Long> flux1 = req.map(r -> r.getVals()) // getVals() return l
浏览 0提问于2018-08-17得票数 1
回答已采纳
1回答
如何过滤空通量
、、
例如，我有下面的代码，它创建一个包含3个数字1,2,3的列表的Mono。我想过滤掉数字1。结果将是一个由2个数字组成的2,3列表。我应该在flatMapMany中做些什么，这样它才能跳过数字1 add(1); add(3);}).map(numbers -> {})如果在我的代码中，当数字
浏览 3提问于2020-04-23得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
