org.springframework.messaging.handler.invocation.reactive

Class ChannelSendOperator<T>

java.lang.Object

<any>

org.springframework.messaging.handler.invocation.reactive.ChannelSendOperator<T>

Type Parameters:

T - the type of element signaled

class ChannelSendOperator<T>
extends <any>

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

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.

Since:

5.2

Author:

Rossen Stoyanchev, Stephane Maldini

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	ChannelSendOperator.State
private class	ChannelSendOperator.WriteBarrier A barrier inserted between the write source and the write subscriber (i.e.
private class	ChannelSendOperator.WriteCompletionBarrier We need an extra barrier between the WriteBarrier itself and the actual completion subscriber.

Field Summary

Fields

Modifier and Type	Field and Description
private <any>	source
private java.util.function.Function<<any>,<any>>	writeFunction

Constructor Summary

Constructors

Constructor and Description
ChannelSendOperator(<any> source, java.util.function.Function<<any>,<any>> writeFunction)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	scanUnsafe(Attr key)
void	subscribe(<any> actual)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

writeFunction

private final java.util.function.Function<<any>,<any>> writeFunction

source

private final <any> source

Constructor Detail

ChannelSendOperator

public ChannelSendOperator(<any> source,
                           java.util.function.Function<<any>,<any>> writeFunction)

Method Detail

scanUnsafe

@Nullable
public java.lang.Object scanUnsafe(Attr key)

subscribe

public void subscribe(<any> actual)