|
|
|
@ -175,6 +175,9 @@ class WriteResultPublisher implements Publisher<Void> {
@@ -175,6 +175,9 @@ class WriteResultPublisher implements Publisher<Void> {
|
|
|
|
|
@Override |
|
|
|
|
void publishComplete(WriteResultPublisher publisher) { |
|
|
|
|
publisher.completedBeforeSubscribed = true; |
|
|
|
|
if(State.SUBSCRIBED.equals(publisher.state.get())) { |
|
|
|
|
publisher.state.get().publishComplete(publisher); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
@Override |
|
|
|
|
void publishError(WriteResultPublisher publisher, Throwable ex) { |
|
|
|
@ -190,6 +193,9 @@ class WriteResultPublisher implements Publisher<Void> {
@@ -190,6 +193,9 @@ class WriteResultPublisher implements Publisher<Void> {
|
|
|
|
|
@Override |
|
|
|
|
void publishComplete(WriteResultPublisher publisher) { |
|
|
|
|
publisher.completedBeforeSubscribed = true; |
|
|
|
|
if(State.SUBSCRIBED.equals(publisher.state.get())) { |
|
|
|
|
publisher.state.get().publishComplete(publisher); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
@Override |
|
|
|
|
void publishError(WriteResultPublisher publisher, Throwable ex) { |
|
|
|
|