T
- the type of element signaledclass 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.
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.
|
Modifier and Type | Field and Description |
---|---|
private <any> |
source |
private java.util.function.Function<<any>,<any>> |
writeFunction |
Constructor and Description |
---|
ChannelSendOperator(<any> source,
java.util.function.Function<<any>,<any>> writeFunction) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
scanUnsafe(Attr key) |
void |
subscribe(<any> actual) |
private final java.util.function.Function<<any>,<any>> writeFunction
private final <any> source
public ChannelSendOperator(<any> source, java.util.function.Function<<any>,<any>> writeFunction)
@Nullable public java.lang.Object scanUnsafe(Attr key)
public void subscribe(<any> actual)