T - 通知された要素の型 public class ChannelSendOperator<T> extends reactor.core.publisher.Mono<VoidSE> implements reactor.core.Scannable
Publisher<T> で書き込みを行い、結果に対して Publisher<Void> を返す書き込み関数がある場合、この演算子は、ソースパブリッシャーがエラーなしでパブリッシュを開始するかどうかがわかるまで、書き込み関数の呼び出しを延期できます。最初の発行がエラーの場合、書き込み機能はバイパスされ、エラーは結果パブリッシャーを介して直接送信されます。それ以外の場合は、書き込み関数が呼び出されます。| コンストラクターと説明 |
|---|
ChannelSendOperator(org.reactivestreams.Publisher<? extends T> source, FunctionSE<org.reactivestreams.Publisher<T>,org.reactivestreams.Publisher<VoidSE>> writeFunction) |
| 修飾子と型 | メソッドと説明 |
|---|---|
ObjectSE | scanUnsafe(reactor.core.Scannable.Attr key) |
void | subscribe(reactor.core.CoreSubscriber<? super VoidSE> actual) |
and, as, block, block, blockOptional, blockOptional, cache, cache, cache, cache, cache, cacheInvalidateIf, cacheInvalidateWhen, cacheInvalidateWhen, cancelOn, cast, checkpoint, checkpoint, checkpoint, concatWith, contextWrite, contextWrite, create, defaultIfEmpty, defer, deferContextual, deferWithContext, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterSuccessOrError, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnSuccessOrError, 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, 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, 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, subscriberContext, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, then, then, thenEmpty, thenMany, thenReturn, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toProcessor, 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, zipWithcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEpublic ChannelSendOperator(org.reactivestreams.Publisher<? extends T> source, FunctionSE<org.reactivestreams.Publisher<T>,org.reactivestreams.Publisher<VoidSE>> writeFunction)