クラス ChannelSendOperator<T>
java.lang.ObjectSE
reactor.core.publisher.Mono<VoidSE>
org.springframework.http.server.reactive.ChannelSendOperator<T>
- 型パラメーター:
T
- 通知された要素の型
public class ChannelSendOperator<T>
extends reactor.core.publisher.Mono<VoidSE>
implements reactor.core.Scannable
ソース
Publisher<T>
で書き込みを行い、結果に対して Publisher<Void>
を返す書き込み関数がある場合、この演算子は、ソースパブリッシャーがエラーなしでパブリッシュを開始するかどうかがわかるまで、書き込み関数の呼び出しを延期できます。最初の発行がエラーの場合、書き込み機能はバイパスされ、エラーは結果パブリッシャーを介して直接送信されます。それ以外の場合は、書き込み関数が呼び出されます。- 導入:
- 5.0
- 作成者:
- Rossen Stoyanchev, Stephane Maldini
ネストされたクラスのサマリー
インターフェース reactor.core.Scannable から継承されたネストクラス / インターフェース
reactor.core.Scannable.Attr<T extends ObjectSE>
フィールドサマリー
インターフェース reactor.core.Scannable から継承されたフィールド
OPERATOR_NAME_UNRELATED_WORDS_PATTERN
コンストラクターのサマリー
コンストラクターコンストラクター説明ChannelSendOperator
(Publisher<? extends T> source, FunctionSE<Publisher<T>, Publisher<VoidSE>> writeFunction) メソッドのサマリー
クラス reactor.core.publisher.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, 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, 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
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース reactor.core.Scannable から継承されたメソッド
actuals, inners, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags, tagsDeduplicated