本文介紹了你能不能壓縮一個單聲道和一個磁通，并為每個磁通值重復這個單聲道的值？的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
是否可以執行類似以下代碼的操作？我有一個進行API調用的服務和另一個返回值流的服務。我需要根據API調用返回的值修改每個值。
return Flux.zip(
someMono.get(),
someFlux.Get(),
(d, t) -> {
//HERE D IS ALWAYS THE SAME AND T IS EVERY NEW FLUX VALUE
});
我嘗試對Mono使用.Repeat()，但它在每次有新的Flux值時都會調用該方法，而且它是一個API調用，所以它不是很好。
可以嗎？
推薦答案
這將說明如何將助焊劑與單聲道組合在一起，以便每次助焊劑發射時，單聲道也會發射。
假設您有一個通量和一個單聲道，如下所示：
// a flux that contains 6 elements.
final Flux<Integer> userIds = Flux.fromIterable(List.of(1,2,3,4,5,6));
// a mono of 1 element.
final Mono<String> groupLabel = Mono.just("someGroupLabel");
首先，我將向您展示我嘗試過的壓縮2的錯誤方法，我想其他人也會嘗試：
// wrong way - this will only emit 1 event
final Flux<Tuple2<Integer, String>> wrongWayOfZippingFluxToMono = userIds
.zipWith(groupLabel);
// you'll see that onNext() is only called once,
// emitting 1 item from the mono and first item from the flux.
wrongWayOfZippingFluxToMono
.log()
.subscribe();
// this is how to zip up the flux and mono how you'd want,
// such that every time the flux emits, the mono emits.
final Flux<Tuple2<Integer, String>> correctWayOfZippingFluxToMono = userIds
.flatMap(userId -> Mono.just(userId)
.zipWith(groupLabel));
// you'll see that onNext() is called 6 times here, as desired.
correctWayOfZippingFluxToMono
.log()
.subscribe();
這篇關于你能不能壓縮一個單聲道和一個磁通，并為每個磁通值重復這個單聲道的值？的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
