org.springframework.http.server.reactive

Class ChannelSendOperator.WriteWithBarrier

java.lang.Object

<any>

org.springframework.http.server.reactive.ChannelSendOperator.WriteWithBarrier

Enclosing class:

ChannelSendOperator<T>

private class ChannelSendOperator.WriteWithBarrier
extends <any>

Field Summary

Fields

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 <any>	writeSubscriber The actual writeSubscriber vs the downstream completion subscriber

Constructor Summary

Constructors

Constructor and Description
WriteWithBarrier(<any> subscriber)

Method Summary

Modifier and Type	Method and Description
void	doComplete()
void	doError(java.lang.Throwable ex)
void	doNext(T item)
protected void	doOnSubscribe(Subscription subscription)
protected void	doRequest(long n)
private boolean	emitCachedSignals() Emit cached signals to the write subscriber.
void	subscribe(<any> writeSubscriber)

Methods inherited from class java.lang.Object

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

Field Detail

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. We're now simply passing data through to the write subscriber.

beforeFirstEmission

private boolean beforeFirstEmission

No emission from upstream yet

item

private T item

Cached signal before readyToWrite

error

private java.lang.Throwable error

Cached 1st/2nd signal before readyToWrite

completed

private boolean completed

Cached 1st/2nd signal before readyToWrite

writeSubscriber

private <any> writeSubscriber

The actual writeSubscriber vs the downstream completion subscriber

Constructor Detail

WriteWithBarrier

public WriteWithBarrier(<any> subscriber)

Method Detail

doOnSubscribe

protected void doOnSubscribe(Subscription subscription)

doNext

public void doNext(T item)

doError

public void doError(java.lang.Throwable ex)

doComplete

public void doComplete()

subscribe

public void subscribe(<any> writeSubscriber)

emitCachedSignals

private boolean emitCachedSignals()

Emit cached signals to the write subscriber.

Returns:

true if no more signals expected

doRequest

protected void doRequest(long n)