project-reactor

0熱

1答えて

reactor.core.publisher.Fluxに加入者を接続するにはどうすればいいですか？

サブスクライバをReactor Fluxに接続したい。しかし、私の小さな例では、任意の出力を生成しません： public static void main(String[] args) throws InterruptedException { Flux.just("a", "b", "c") .subscribe(new BaseSubscriber<String>()

1熱

1答えて

プロジェクトの原子炉の動作原理

私はプロジェクト原子炉、モノズ、フラックスのことについてたくさん研究していますが、私はこのテーマについて少し混乱しています。ここでは、私が理解していることについていくつか前提を述べたいと思いますが、私は正しい道にいるかどうかを教えてください。 Reactiveのコンセプトに興味があった理由は、Jetty Serverで「Continuations」と呼ばれるコンセプトと似ていると思ったのですが、

1熱

1答えて

Fluxesはどのようにガベージコレクションされていますか？

Fluxを作成したとしましょう。このFluxは作成中にいくつかのリソースにアクセスできるようになっており、Cancel/Complete（たとえば、いくつかの外部リソースを解放する）でクリーンアップをしたいと思います。最終的には、このFluxへのポインタをすべて削除するので、ガベージコレクションに使用できるようになります。ガベージコレクションではどうなりますか？ FluxはCancelシグナルを受

0熱

1答えて

原子炉StepVerifier.withVirtualTimeブロック無期限

私はReactorの仮想時間機能を使用しようとしているが、テストブロック無期限（タイムアウトなし）または（タイムアウト付き）AssertionErrorをスローしています： @Test public void test() { StepVerifier.withVirtualTime(() -> Flux.just(1, 2, 3, 4).delayElements(Du

0熱

2答えて

WebFlux機能：空のFluxを検出して404を返す方法は？

私は以下の簡略化されたハンドラ関数（Spring WebFluxとKotlinを使用する機能的API）を持っています。しかし、Fluxが空の場合、空のFluxを検出して404にnoContent（）を使用する方法のヒントが必要です。 Fluxから return customerMono .flatMap(c -> ok().body(BodyInserters.fromObject(

0熱

1答えて

春WebFlux：春データリMongoDBの

内のブロック（）メソッドの戻り値はnull iは、プロジェクトの原子炉を学び、問題を抱えているしようとしています。 @Test @DisplayName("check that standaloneUser fields are correct") void validateUserFields() { userService.save(standaloneUser).subscri

0熱

3答えて

春WebFlux：反応性MongoDBの

私は春の反応器に新たなんだので、私は（kotlinに）この単純春データをリファクタリングしたい方法：このような

0熱

1答えて

Spring WebFlux、WebClient POST交換をどのようにデバッグできますか？

WebClientリクエストを作成する際に間違っていたことを理解するのに問題があります。私は実際のHTTPリクエストがどのようなものか理解したいと思います。私は、APIを構築するためにSpring5の反応性のツールを使用しています POST /rest/json/send HTTP/1.1 Host: emailapi.dynect.net Cache-Control: no-cache P

0熱

1答えて

Reactorでhttp ratelimitedサービスを再試行する

私はReactor 3をJavaで使用しているだけです。 reactor-nettyを使ってhttpサービス用のクライアントを実装したいと思います。これまでは、非常に基本的なHTTP要求が完全に送信されています。しかし、このサービスは、クライアントがラテリットを守ることを期待しています（クライアントに伝統的なX-RateLimit-Limit,X-RateLimit-Remainingなどのヘッダ