問題タブ [project-reactor]

私は Reactor を使用しており、いくつかのイベントを発行するフラックスを作成しています。私の問題は、フラックスに非フィルター サブスクライバーを追加しない限り、フィルターを使用して作成したサブスクライバーがしばらくすると失敗することです。

追加のサブスクライバーがいる場合、コードは正常に機能します。

私が間違っていることについてのアイデアはありますか?

よろしくお願いします

件名として、ユースケースとその使用方法がわかりません。

ソース コードを掘り下げると、mono 自体が から にキャストされているようMono<T>ですMono<Signal<X>。

そのJavadocによると、最初の値が購読と最初の次のシグナルの間の経過時間になる場所Mono.elapse()を生成します。Mono<Tuple2<Long, T>>

次のテストは機能しません

例外がスローされます：

経過時間は少なくとも 1000 ミリ秒になると予想していましたが、実際にはわずか 11 ミリ秒でした。

ここで何かが恋しいですか？

そのJavadocによるとMono<T>.materialize()：

受信した onNext、onError、および onComplete シグナルを Signal に変換します。エラーはシグナルとして具体化されるため、伝播は停止され、onComplete が発行されます。完全なシグナルは、最初に Signal.complete() を発行し、次にフラックスを効果的に完了します。

これは、エラーが発生していないときにPublisher返されたmaterializeが少なくとも 2 つのシグナルを発する必要があることを意味します。

• Signal.next
• Signal.complete

ただし、このメソッドの戻り値の型は、Mono<Signal<T>>単一のイベントの発行のみを許可します。だから私は混乱しています。コードは

ドキュメントによると：

応答本文は、次のいずれかになります。

• Account — 指定された Account をブロックせずにシリアル化します。同期のノンブロッキング コントローラー メソッドを意味します。

同期コントローラ メソッドがノンブロッキングになるのはなぜですか? 矛盾しているように聞こえます。