パッケージ 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, 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