project-reactor

5熱

4答えて

ReactorとRxJavaを使用してリアクティブスタイルのコードを勉強し続けています。私はリアクティブコーディングがシングルスレッド実行に比べてCPUの利用率を向上させることを理解しています。リアクティブプログラミングとWebベースアプリケーションの命令型プログラミングの具体的な比較はありますか？非反応型プログラミングよりもリアクティブプログラミングを使用することで、パフォーマンスの向上、ス

2熱

1答えて

オペレータ "publishOn（）"とスレッドアフィニティプロジェクトで

publishOn()（またはRxJavaの場合はobserveOn()）演算子がスレッドアフィニティの観点からどのように機能するかはっきり分かりません。私は、任意の加入者が同じスレッドで処理されることを、このオペレータが保証することを思ったが、例えば、以下の私の理解壊れている：私は次の出力を参照結果 Flux<String> started = ep.publishOn(scheduler);

0熱

1答えて

SpringとAkkaを使用したリアクティブストリーム

この質問を書く瞬間、私はSpring Framework 5.0.0.M5とAkka 2.4.17を使用しています。プロジェクトでは、現在Akkaの俳優メッセージやストリームを使用しています。 Spring Framework v5にはストリームも含まれています。反応エンジン/ SPI、炉心およびIOモジュールの両方が最終的に春、RxJava、アッカストリーム、Ratpackと組み合わせて、集中ユ

0熱

2答えて

計算された値を持つ原子炉設計

私はProject Reactorを使用するアプリケーションの設計方法を理解しようとしています。他の値に基づいて値を更新する必要があるアプリケーションのようなスプレッドシートがあるとします。値には数式が定義されています。ですから、例えば： A = 1.5B + C 私はA、B、Cは全てフラックスのいくつかの種類になると思います（私は、私が使用する特定の実装のわからないんだけど）、のいずれかの理由値

1熱

2答えて

RxJavaまたはReactorの例外宣言

Observableを返すAPIがあるとします。 APIクライアント/ユーザーに、APIが特定の例外をスローする可能性があることを伝えるにはどうすればよいですか？プレーンJavaで、それは非常に簡単です：私たちが観測にそれを変更した場合 List<Student> findStudentsByGrade(int grade) throws NegativeGradeException,

0熱

2答えて

購読中のモノでonNextとonCompleteコールを受け取ることができません

私はリアクターライブラリーを試していましたが、onNextまたはonComplete呼び出しで戻ってくるモノが決して戻ってこない理由は分かりません。私は非常に些細な事を欠いていると思う。ここにサンプルコードがあります。 MyServiceService service = new MyServiceService(); service.save("id") .map(myU

0熱

1答えて

ProjectReactor StepVerifier expectNoEventをテストする方法は？

expectNoEventを確認するのが難しいです。 StepVerifier.withVirtualTime((Supplier<Publisher<?>>)() -> Flux.just(1, 2, 3).cache(Duration.ofSeconds(10))) .thenAwait(Duration.ofSeconds(11)) .expectNoEvent

0熱

1答えて

Flux.concatMapIterableとFlux.flatMapIterableの違いは何ですか？

大理石図に従ってflatMapがインターリーブされたFlux.concatMapおよびFlux.flatMapとは異なり、大文字の図表に従ってFlux.concatMapIterableとFlux.flatMapIterableの両方がインターリーブされません。 Flux.concatMapIterable図であり、Flux.flatMapIterable図は、シーケンス出力を生じるの両方です

0熱

1答えて

リアクティブストリームの検証として例外をスローする最も適切な方法

私は妥当性検査を適用するための1つのステップを望むリアクティブストリームを用意しています。それを行うには一般的に受け入れられているスタイルがありますか？私には、then()、filter()、およびmap()に3つのオプション（Monoを使用）があることがわかります。 filter()その中で、私は実際には別のストリームにストリームまたはスイッチ内のデータの種類を変更するつもりはないよ、私が欲しい

0熱

1答えて

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

私はStateをとり、新しいStateとValueを生成する関数を持っています。どのようにしてFluxを作成できますか？やコード発言する：xxxは何 Function<State, Pair<State, Value> f = ...; Flux<Value> values = xxx(f); を？