パッケージ org.springframework.http.server.reactive

クラス ChannelSendOperator<T>

java.lang.ObjectSE
reactor.core.publisher.Mono<VoidSE>
org.springframework.http.server.reactive.ChannelSendOperator<T>
型パラメーター:
T - 通知された要素の型
実装されたすべてのインターフェース:
Publisher<VoidSE>、reactor.core.CorePublisher<VoidSE>、reactor.core.Scannable
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)

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    ObjectSE
    scanUnsafe(reactor.core.Scannable.Attr key)
    void
    subscribe(reactor.core.CoreSubscriber<? super VoidSE> actual)

    クラス 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, 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

    クラス 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

  • コンストラクターの詳細

  • メソッドの詳細

    • scanUnsafe

      @Nullable public ObjectSE scanUnsafe(reactor.core.Scannable.Attr key)
      次で指定:
      インターフェース reactor.core.Scannable の scanUnsafe 

    • subscribe

      public void subscribe(reactor.core.CoreSubscriber<? super VoidSE> actual)
      次で指定:
      インターフェース reactor.core.CorePublisher<T> の subscribe 
      次で指定:
      クラス reactor.core.publisher.Mono<VoidSE> の subscribe