クラス ChannelSendOperator<T>
- 型パラメーター:
T- 通知された要素の型
- 実装されているすべてのインターフェース:
Publisher<VoidSE>, CorePublisher<VoidSE>, Scannable
書き込み用のソース
Publisher<T> を受け入れ、結果として Publisher<Void> を返す書き込み関数がある場合、この演算子は、ソースパブリッシャーがエラーなしでパブリッシュを開始するかどうかがわかるまで、書き込み関数の呼び出しを延期できます。最初の出力がエラーの場合、書き込み関数はバイパスされ、エラーは結果パブリッシャーを通じて直接送信されます。それ以外の場合は、書き込み関数が呼び出されます。- 導入:
- 5.0
- 作成者:
- Rossen Stoyanchev, Stephane Maldini
ネストされたクラスの概要
インターフェース Scannable から継承されたネストクラス / インターフェース
Scannable.Attr<T>フィールドのサマリー
インターフェース Scannable から継承されたフィールド
OPERATOR_NAME_UNRELATED_WORDS_PATTERNコンストラクターの概要
コンストラクターコンストラクター説明ChannelSendOperator(Publisher<? extends T> source, FunctionSE<Publisher<T>, Publisher<VoidSE>> writeFunction) 方法の概要
クラス Mono から継承されたメソッド
and, as, block, block, blockOptional, blockOptional, cache, cache, cache, cache, cache, cacheInvalidateIf, cacheInvalidateWhen, cacheInvalidateWhen, cancelOn, cast, checkpoint, checkpoint, checkpoint, concatWith, contextCapture, contextWrite, contextWrite, create, defaultIfEmpty, defer, deferContextual, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMapIterable, flatMapMany, flatMapMany, flux, from, fromCallable, fromCompletionStage, fromCompletionStage, fromDirect, fromFuture, fromFuture, fromFuture, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, log, log, map, mapNotNull, materialize, mergeWith, metrics, name, never, ofType, onAssembly, onErrorComplete, onErrorComplete, onErrorComplete, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, share, single, singleOptional, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, tap, tap, tap, then, then, thenEmpty, thenMany, thenReturn, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toString, transform, transformDeferred, transformDeferredContextual, using, using, using, using, usingWhen, usingWhen, when, when, whenDelayError, whenDelayError, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipWhen, zipWhen, zipWith, zipWithクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース Scannable から継承されたメソッド
actuals, inners, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags, tagsDeduplicated
コンストラクターの詳細
ChannelSendOperator
メソッドの詳細
scanUnsafe
- 次で指定:
- インターフェース
ScannableのscanUnsafe
subscribe