project-reactor

0熱

1答えて

Mono.subscribe（consumer、errorConsumer、completeConsumer、subscriptionConsumer）はconsumerおよびcompleteConsumerを呼び出しませんか？

件名として、Mono.subscribeの4番目の変種は、成功した消費者と完全な消費者を呼び出すようではありません。サブスクリプションコンシューマを呼び出すだけです。次のコードは、あなたが最初のrequestを駆動するためConsumer<Subscription>とsubscribeのバージョンが意図されているためです CountDownLatch latch = new CountDownL

1熱

1答えて

スプリング5のWebリ - <a href="http://docs.spring.io/spring/docs/5.0.0.M4/spring-framework-reference/htmlsingle/#web-reactive-http-body" rel="nofollow noreferrer">doc</a>によればDTOレスポンスボディ変換

約解明：レスポンスボディは、次のいずれか：アカウント - 与えられたアカウントをブロックすることなく、シリアライズ。同期非ブロッキングコントローラメソッドを意味します。どのように同期コントローラメソッドが非ブロック化できるのですか？それは矛盾のように聞こえる。ここ

1熱

2答えて

リアクタ3 'インターバルバッファ' Flux？

既存のFlux演算子を使用して、Fluxが入力値を複数のリストに返すようにするにはどうすればよいでしょうか？

1熱

1答えて

フラックス上でpublishOnとsubscribeOnの両方を使用すると、何も起こりません

私はsubscribeOnとpublishOnの両方を使用するときは何も表示されません。 1つだけを使用すると印刷されます。私がsubscribeOn（Schedulers.immediate（））を使用したり、弾力性を持っていれば動作します。これは何故でしょうか？ publishOnは、どのスレッドで公開され、サブスクライバが実行するスレッドでサブスクライブするかに影響すると私は理解しました

1熱

1答えて

Project Reactor - Java 8ストリームからFluxを作成する方法

Java 8ストリームは再利用を許可していません。これは、x（i）* x（i-1）のような関係を計算するためにスライディングウィンドウの磁束を作成するときにストリームを再利用する方法についてのパズルを作成します。次のコードは、シフト演算子の考え方に基づいています。最初のストリームをskip（1）でシフトして2番目のストリームを作成します。ここで Flux<Integer> primary = F

0熱

1答えて

Reactor 3.x（Java）：ウェブ掻き取りのため

ここにはリアクタNoobがあります。これは、HowTo質問の詳細です。私は、検索結果のページ単位のセットを含むスクラップしたいウェブサイトを持っているとしましょう。検索結果ページの数は不明です。各検索ページには、次のページへのリンクがあります。私はすべてのページからすべての検索結果を削り取り、それぞれの検索結果を処理したいと思います。 Reactor（Mono/Flux）をJavaでどのように

3熱

1答えて

FluxからMonoに変換する

1要素のFluxからMonoに変換するにはどうすればよいですか？ Flux.fromArray(arrayOf(1,2,1,1,1,2)) .distinct() .take(1) これをモノ（1）にするにはどうすればよいですか？

0熱

1答えて

Reactorで閉鎖可能なリソースを適切に管理する方法

すべての作業が完了したら閉じなければならないhttpクライアントとexecutorがあります。 https://github.com/meddle0x53/learning-rxjava/blob/master/src/main/java/com/packtpub/reactive/chapter08/ResourceManagement.java マイリソースの作成方法：：私はその後、使用 pu

0熱

1答えて

Mono.dematerialize（）の使い方？

件名として、私はユースケースとその使い方を理解していません。ソースコードを掘ることは、Mono<T>からMono<Signal<X>にモノ自身をキャスティングしているようです。 Javadocの中に示されているように