private class ChannelSendOperator.WriteBarrier
extends java.lang.Object
Acts as:
Also uses ChannelSendOperator.WriteCompletionBarrier
to communicate completion
and detect cancel signals from the completion subscriber.
Modifier and Type | Field and Description |
---|---|
private boolean |
beforeFirstEmission
No emission from upstream yet
|
private boolean |
completed
Cached 1st/2nd signal before readyToWrite
|
private java.lang.Throwable |
error
Cached 1st/2nd signal before readyToWrite
|
private T |
item
Cached signal before readyToWrite
|
private boolean |
readyToWrite
We've at at least one emission, we've called the write function, the write
subscriber has subscribed and cached signals have been emitted to it.
|
private Subscription |
subscription |
private ChannelSendOperator.WriteCompletionBarrier |
writeCompletionBarrier |
private <any> |
writeSubscriber
The actual writeSubscriber from the HTTP server adapter
|
Constructor and Description |
---|
WriteBarrier(<any> completionSubscriber) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
Context |
currentContext() |
private boolean |
emitCachedSignals() |
void |
onComplete() |
void |
onError(java.lang.Throwable ex) |
void |
onNext(T item) |
void |
onSubscribe(Subscription s) |
void |
request(long n) |
private <any> |
requiredWriteSubscriber() |
void |
subscribe(<any> writeSubscriber) |
private final ChannelSendOperator.WriteCompletionBarrier writeCompletionBarrier
@Nullable private Subscription subscription
private boolean readyToWrite
private boolean beforeFirstEmission
@Nullable private java.lang.Throwable error
private boolean completed
@Nullable private <any> writeSubscriber
public final void onSubscribe(Subscription s)
public final void onNext(T item)
private <any> requiredWriteSubscriber()
public final void onError(java.lang.Throwable ex)
public final void onComplete()
public Context currentContext()
public void request(long n)
private boolean emitCachedSignals()
public void cancel()
public void subscribe(<any> writeSubscriber)