project-reactor

1熱

1答えて

私は4スレッドからTopicProcessorにメッセージを公開し、サブスクライバでメッセージを単純にコレクションに追加する簡単なテストを行っています。コードは以下の通りです： @Test public void testProcessingMessages() throws Exception { int numberOfMessages = 1000; TopicPro

0熱

1答えて

プロジェクト・リアクタでSpringキャブルを使用する

私はSpringプロジェクト・リアクタをリアクション・ストリーム実装として使用していますが、リアクション・ストリームでSpringキャッシュ抽象化を使用できるかどうかは疑問でした。私はそれらを一緒に使うことができるかどうかを知りたかったのですが、誰かがこれを解決したらどうしましたか？ありがとう！

1熱

2答えて

Fluxからの結果とMonoの結果を合わせる

Project reactorと1つの場所で私が少し苦労しているところは、Monoから来たものとFluxをどのように組み合わせるかです。ここに私のユースケースがあります： public interface GroupRepository { Mono<GroupModel> getGroup(Long groupId); } public interface UserReposi

1熱

1答えて

Spring WebFluxクライアントを使用してRESTエンドポイントを消費中にエラーが発生しました

Springリアクタ3（WebFlux）を使用し始めました.WebClientを使用してFluxを返すためにRESTエンドポイントを使用しようとすると、アプリケーションクラス： @Bean public WebClient client(){ return WebClient.create("http://localhost:8080"); } @Bean CommandLi

0熱

1答えて

信号のアップストリーム - 春の原子炉

への呼び出しを実行が失敗したとき、私は、次のコードを、 ClassA { Mono<Integer> execute(ListElement listElement) { //returns mono on success and throwable on failure } } Flux.fromIterable(list) .flatMap(listEle

0熱

1答えて

他のパブリッシャーとのバッファー - スプリングリアクター

Flux.buffer（Publisher other）がどのように機能するかの例を挙げることはできますが、元のフラックスを複数のリストに分割するために他のパブリッシャーを利用することはできません。例： List<String> strings = new ArrayList<>(); strings.add("A"); strings.add("B"); Flux

0熱

1答えて

Reactorでの要求の制限率

私は、プロジェクト・リアクターを使用して、残りを使用してWebサービスからデータをロードしています。これは、複数のスレッドと並行して行われます。私はWebサービスのレート制限を開始しているので、これらのエラーを避けるために、毎秒最大10個のリクエストを送信したいと思います。原子炉を使ってどうすればいいですか？ zipWith（Mono.delayMillis（100））を使用していますか？それとも

1熱

1答えて

Blocking I/Oタスク用のParallelFluxとflatMap（）との比較

私はBlockingタスク（ネットワークコール、レスポンスを待つ必要がある）を含むProject Reactorチェーンを持っています。複数のブロック作業を同時に実行したい。それはParallelFluxまたはflatMap（いずれかのように思える）を使用することができ、ベアボーン例： Flux.just(1) .repeat(10) .parallel(3) .r