如何通過將狀態轉換爲值和新狀態的函數創建Flux？

Question

我有一個函數需要State併產生一個新的State和一個Value。

我該如何創建Flux？

或者說話代碼：

Function<State, Pair<State, Value> f = ...; 

Flux<Value> values = xxx(f); 

什麼是xxx？

Answer 1

我瞭解到，你可以做什麼，我跟Flux.generate想輕鬆：

Flux.generate(
    () -> initialState, 
    (state, sink) -> { 
     Pair<State, Value> p = f.apply(state); // get the new state and the value 
     sink.next(p.right); // this is basically calling the subscriber with the value 
     return p.left; // this returns the new state 
    } 
);