project-reactor

1熱

1答えて

私はこの小さなアプリケーションでProject Reactor 3.0を学ぼうとしていました。私はFlux.zip（）関数を構成して、変数をMovieオブジェクトに結合するのに苦労しています。 Reactorでは戻り値の型がFlux<Tuple5<>>のようです。 RxJava2では、Function5<>を返します。 RxJava2 Single<Movie> movie = Single.zi

2熱

1答えて

プロジェクト・リアクター：各要素の（スロットル）放出を遅らせる方法は？

は、以下のFlux Flux.range(1, 5) .parallel(10) .runOn(Schedulers.parallel()) .map(i -> "https://www.google.com") .flatMap(uri -> Mono.fromCallable(new HttpGetTask(httpClient, uri))) Ht

0熱

1答えて

Java Spring Reactorに相当するRxJavaComputationExpressionsがありますか？

私はJava Reactor Monoタイプで作業しています。私は 'ifThen'を与える非常に単純な構造をしたいと思います。 RxJava RxJavaComputationExpressionsの実装がありますが、残念ながら私はSpring Reactorに縛られています。 Reactorに類似の実装が存在するのでしょうか、それとも独自にロールバックする必要がありますか？

3熱

1答えて

Spring SecurityとProject Reactorの統合

リクエストスレッドにバインドされた認証に依存するアプリケーションがあります（外部RESTサービスを呼び出すときなど、RestTemplateの要求インターセプタによって送信HTTPヘッダーに透過的に表示されます）。私はこのアプリケーションでProject Reactorを使用して反応パターンを学習して適用しています。私はREST API呼び出しを反応させることから始めました。これらはSchedu

1熱

2答えて

エラーの観測可能な加入者の変更

エラー時に加入者を変更するには？私はデータベースからのコールドストリームを消費しています。次のケースを参照してください。 return coctailBundleStream .doOnNext(c -> { hostnames.add(c.get(KEY_HOSTNAME)); // [A] sendToOutboundQueue(c.get(KEY_C

3熱

3答えて

Spring Boot 2 Reactor Flux APIの角度クライアント

Java Project ReactorFlux APIのAngular 4クライアントを作成するにはどうすればよいですか？以下のサンプルには、2つのAPI、Mono API、 APIはFluxです。どちらもcurlから動作します。 Angular 4（4.1.2）ではMono APIのみが動作します。 Angular 4をFlux APIで使用するにはどうすればよいですか？ロンボク-EDイベント

0熱

1答えて

プロジェクト・リアクターAPIのFlux :: sampleTimeoutメソッドの目的は何ですか？

のJavaドキュメントには、次のように言う：は、その特定の最後の値のための出版社によって提供される時間窓の間に放出された新しい値が存在しない場合にのみ、このフラックスからの最後の値を発します。しかし、私は上記の説明が混乱していることを発見しました。私はgitter chatでRxJavaのdebounceと似ています。誰かが例を挙げて説明してもらえますか？私は徹底的な検索を行った後、どこでもこ

0熱

1答えて

Project Reactor asyncはエラー時に再試行を伴うメールを送信します

ユーザー登録後にデータを送信する必要があります。私はメインスレッドで最初の試行をしたいが、何かエラーがある場合は、10分間隔で5回再試行したい。 @Override public void sendRegisterInfo(MailData data) { Mono.just(data) .doOnNext(this::send) .doOnError(ex -

0熱

1答えて

元のシーケンスが終了しないようにエラーを処理する方法はありますか？

reference guideのエラー処理セクションで、エラー処理オペレータでエラーが処理されても、元のシーケンスが終了することに注意してください。ストリームのエラーが値に置き換えられ、元のシーケンスが続行されるなど、エラーを処理する方法はありますか？ "エラー処理オペレータについて学ぶ前に、反応シーケンスのエラーはターミナルイベントであることに注意する必要があります。エラー処理オペレータが使用さ