我一直在試圖用這個小應用程序學習Project Reactor 3.0。我正在努力編寫一個Flux.zip()函數來將變量組合到Movie對象中。在Reactor中,返回類型似乎是Flux<Tuple5<>>
。在RxJava2中它返回一個Function5<>
。構建Flux.zip的項目反應堆()
RxJava2
Single<Movie> movie = Single.zip(getDesc(id), getCategory(id), getName(id), getRating(id),
(Function5<Integer, String, String, String, Double, Object>) (desc, cat, name, rating) ->
new Movie(id.blockingGet(), name, desc, cat, rating)).cast(Movie.class);
反應堆
Flux<Tuple5<Integer, String, String, String, Double>> tuple =
Flux.zip(id, getDesc(id), getCategory(id), getName(id), getRating(id));
而不是返回Flux<Tuple5<>>
我想回到一個Tuple5<>
或別的東西來建立電影就像RxJava的。我不想訂閱Tuple,因爲我試圖在Spring Web Reactive中返回這個。我暫時通過訂閱解決了它,但我想知道是否可以像RxJava一樣做。
時間戳1:07:54處的this video中的示例顯示它可能在舊版本中。
歡迎任何解決方案或建議!