class WriteResultPublisher
extends java.lang.Object
ServerHttpResponse#writeWith(Publisher)
.Modifier and Type | Class and Description |
---|---|
private static class |
WriteResultPublisher.ResponseBodyWriteResultSubscription |
private static class |
WriteResultPublisher.State |
Modifier and Type | Field and Description |
---|---|
private static Log |
logger |
private boolean |
publisherCompleted |
private java.lang.Throwable |
publisherError |
private java.util.concurrent.atomic.AtomicReference<WriteResultPublisher.State> |
state |
private <any> |
subscriber |
Constructor and Description |
---|
WriteResultPublisher() |
Modifier and Type | Method and Description |
---|---|
private boolean |
changeState(WriteResultPublisher.State oldState,
WriteResultPublisher.State newState) |
void |
publishComplete()
Publishes the complete signal to the subscriber of this publisher.
|
void |
publishError(java.lang.Throwable t)
Publishes the given error signal to the subscriber of this publisher.
|
void |
subscribe(<any> subscriber) |
private static final Log logger
private final java.util.concurrent.atomic.AtomicReference<WriteResultPublisher.State> state
private <any> subscriber
private volatile boolean publisherCompleted
private volatile java.lang.Throwable publisherError
public final void subscribe(<any> subscriber)
private boolean changeState(WriteResultPublisher.State oldState, WriteResultPublisher.State newState)
public void publishComplete()
public void publishError(java.lang.Throwable t)