public class ChannelSendOperator<T>
extends <any>
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)