project-reactor

1熱

1答えて

私はwebfluxで小さな概念実証に取り組んでいます。私のアプリケーションの1つの部分では、（JDBCを介した）データベースと通信したいと思います。これはブロックしていて、原子炉には適していません。それにもかかわらず、この概念実証のために、私は次のトリックを考えています：は、専用のスレッドプールを定義したスレッド等しいJDBC接続プールのサイズの固定数でExecutorServiceとして（のは

0熱

1答えて

反応器内のGroupedFluxを減らす

私は1つのフラックスに異なる種類のオブジェクトがあり、その中にタイプ別にグループ要素を入れて、それぞれのグループを減らしたい。ここにこれを行う簡単なコードです。 Flux<Item> item=Flux.just(new Item("item1"), new Item("item2")); Flux<Item2> item2=Flux.just(new Item2(4.0f), new

0熱

1答えて

junitテストでリアクタスイッチオフが予期どおりに動作しない

以下の方法でテストを行っています。 ` class ScrapedRecipeCache @Autowired constructor(private val cache: RecipeScrapingCacheService, private val recipeService: RecipeService) : ScrapedRecipeProvider {

0熱

1答えて

インナーFlux/Monoを自動的に購読するには？

私はロングインナーフラックスの大きさであるロングのフラックス、変身したい（有界）フラックスのフラックスを持っている： Flux.just(Flux.just(1, 2, 3), Flux.just(1, 2) ) .map(Flux::count) .log() .subscribe(); 実行ログは以下の通りです： onSubscribe([Synchro

0熱

1答えて

リアクティブプログラミングでのアグレッシブタイムアウトの利点利点

ブロッキングの世界では、高速で障害を起こし、基盤リソース（セクション5.1のhttps://pragprog.com/book/mnee/release-it）をリリースするために、積極的なタイムアウトを設定することを強く推奨します。非同期/非ブロッキングの世界では、要求はメインスレッドをブロックしておらず、リソースはすぐ後で処理できるようになります。タイムアウトはまだ必要ですが、積極的な値を設

0熱

1答えて

io.projectreactorはどこですか？reactor-bom：Bismuth-RC1？

Spring Reactor Core 3.1.0.RC1 et.al私はio.projectreactorを見つけることができません：reactor-bom：Bismuth-RC1。私は最新のSpring WebFluxでテストしたいと思います。どんなヒントもありがとうございます。

1熱

1答えて

Refactor ReactiveCrudRepository.deleteAll（）。ブロック（ノンブロッキングコード）

このコードをリアクションスタイルでリファクタリングするのに誰かが助けてくれますか？ userService.deleteAll().then().block(); userService.saveAll(Flux.just(candidate, tech, pm, hr)).then().block(); 私は、この実装はthen(…)方法のonNext(…)によって簡素化することができると

1熱

1答えて

Socket.IO-client Java用のReactor Fluxプロキシー

私はSocket.IO-client Javaからデータを取得するSpring WebFluxエンドポイントを実装しています。 Fluxストリームに入ってくるデータを収集する方法がわかりません。新しいFluxをいくつか作成し、それを受信データに登録することはできますか？アドバイスをありがとう。 @GetMapping("/streaming", produces = MediaType.APPLI

1熱

1答えて

ブロック操作にMono <Object> .publishOn（Schedulers.elastic）を使用することは可能ですか？

ブロック操作を使用しているとき、私たちは、私は私のパブリッシャが（例の場合：フラックス）の項目のリストを公開したときに、それは理にかなっていることを理解Publisher<Object>.publishOn(Schedulers.elastic).subscribe(//blocking operations go here) を使用する必要があり、反応の流れで理解し、将来のアイテムは、現在のを待

0熱

3答えて

何JSではカップルのアイテム

に参加するためにフラックス/モノラルで使用されるべきであることは、あなたが Promise.join を使用することができます。しかし、私はフラックス/モノラルのため、このような解決策を見つけることができませんでした約束します。別のアイテムを扱った後に一緒に使う必要がある場合、ベストプラクティスは何ですか？