状態を値と新しい状態に変換する関数からFluxを作成するにはどうすればよいですか？

Question

私はStateをとり、新しいStateとValueを生成する関数を持っています。

どのようにしてFluxを作成できますか？

やコード発言する：xxxは何

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

Flux<Value> values = xxx(f); 

を？

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 
    } 
);