WriteResultPublisher

Nested Classes
Modifier and Type	Class and Description
`private static class`	`WriteResultPublisher.State` Represents a state for the `Publisher` to be in.
`private static class`	`WriteResultPublisher.WriteResultSubscription` Subscription to receive and delegate request and cancel signals from the subscriber to this publisher.

Fields
Modifier and Type	Field and Description
`private boolean`	`completedBeforeSubscribed`
`private java.lang.Throwable`	`errorBeforeSubscribed`
`private java.lang.String`	`logPrefix`
`private static Log`	`rsWriteResultLogger` Special logger for debugging Reactive Streams signals.
`private java.util.concurrent.atomic.AtomicReference<WriteResultPublisher.State>`	`state`
`private <any>`	`subscriber`

Constructors
Constructor and Description
`WriteResultPublisher(java.lang.String logPrefix)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`private boolean`	`changeState(WriteResultPublisher.State oldState, WriteResultPublisher.State newState)`
`void`	`publishComplete()` Invoke this to delegate a completion signal to the subscriber.
`void`	`publishError(java.lang.Throwable t)` Invoke this to delegate an error signal to the subscriber.
`void`	`subscribe(<any> subscriber)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

private final java.util.concurrent.atomic.AtomicReference<WriteResultPublisher.State> state

@Nullable
private volatile <any> subscriber

private volatile boolean completedBeforeSubscribed

@Nullable
private volatile java.lang.Throwable errorBeforeSubscribed

private final java.lang.String logPrefix

public WriteResultPublisher(java.lang.String logPrefix)

public final void subscribe(<any> subscriber)

publishComplete
```
public void publishComplete()
```
Invoke this to delegate a completion signal to the subscriber.

publishError
```
public void publishError(java.lang.Throwable t)
```
Invoke this to delegate an error signal to the subscriber.

private boolean changeState(WriteResultPublisher.State oldState,
                            WriteResultPublisher.State newState)

Class WriteResultPublisher