Spring Messaging 6.1.4 · org.springframework.messaging.handler.invocation.reactive.ChannelSendOperator

----------------------

Note

This class was copied from org.springframework.http.server.reactive.ChannelSendOperator and is identical to it. It's used for the same purpose, i.e. the ability to switch to alternate handling via annotated exception handler methods if the output publisher starts with an error.

----------------------

Given a write function that accepts a source Publisher<T> to write with and returns Publisher<Void> for the result, this operator helps to defer the invocation of the write function, until we know if the source publisher will begin publishing without an error. If the first emission is an error, the write function is bypassed, and the error is sent directly through the result publisher. Otherwise the write function is invoked.

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static enum	ChannelSendOperator.State
private class	ChannelSendOperator.WriteBarrier A barrier inserted between the write source and the write subscriber (i.e. the HTTP server adapter) that pre-fetches and waits for the first signal before deciding whether to hook in to the write subscriber.
private class	ChannelSendOperator.WriteCompletionBarrier We need an extra barrier between the WriteBarrier itself and the actual completion subscriber.

Field Summary

Modifier and Type	Field and Description
private final Flux<T>	source
private final Function<Publisher<T>, Publisher<Void>>	writeFunction

Constructor Summary

Access	Constructor and Description
public	ChannelSendOperator(Publisher<? extends T> source, Function<Publisher<T>, Publisher<Void>> writeFunction)

Method Summary

Modifier and Type	Method and Description
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
public void	subscribe(CoreSubscriber<? super Void> the `Subscriber` interested into the published sequence actual) Implements abstract reactor.core.publisher.Mono.subscribe. Implements reactor.core.CorePublisher.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut.

Inherited from 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

pack-priv Class ChannelSendOperator<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary