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 |
completed
Cached onComplete signal before readyToWrite.
|
private long |
demandBeforeReadyToWrite
Recursive demand while emitting cached signals.
|
private java.lang.Throwable |
error
Cached error signal before readyToWrite.
|
private T |
item
Cached data item before readyToWrite.
|
private ChannelSendOperator.State |
state
Current state.
|
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) |
private void |
releaseCachedItem() |
void |
request(long n) |
private <any> |
requiredWriteSubscriber() |
void |
subscribe(<any> writeSubscriber) |
private final ChannelSendOperator.WriteCompletionBarrier writeCompletionBarrier
@Nullable private Subscription subscription
@Nullable private java.lang.Throwable error
private boolean completed
private long demandBeforeReadyToWrite
private ChannelSendOperator.State state
@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()
private void releaseCachedItem()
public void subscribe(<any> writeSubscriber)