Ben tipik kod - Bir Consumer bir depo ile çalışan Sonra @Consumer
public class ApplicationService {
@Selector(value="/applications/id", type = SelectorType.URI)
@ReplyTo
public Applic
ben resources birbirinden bağımsız getirilen edilebilir bir REST isteği yürütülürken performansını artırmak için mevcut bir Spring 4 uygulamasına Reactor 2x bütünleştirmek çalışıyorum, bir nevi harita
Iterable 8 öğesinden() oluşturulan bir flux var. Her bir akı emisyonu için, bir senkronize olmayan bir yöntemi çağırmak istiyorum. Ben çalışmak ve sonunda ben fluxflux<CompletableFuture<Boolean>> dönü