|
|
@ -320,8 +320,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> { |
|
|
|
<T> void onDataAvailable(AbstractListenerReadPublisher<T> publisher) { |
|
|
|
<T> void onDataAvailable(AbstractListenerReadPublisher<T> publisher) { |
|
|
|
if (publisher.changeState(this, READING)) { |
|
|
|
if (publisher.changeState(this, READING)) { |
|
|
|
try { |
|
|
|
try { |
|
|
|
boolean demandAvailable = publisher. |
|
|
|
boolean demandAvailable = publisher.readAndPublish(); |
|
|
|
readAndPublish(); |
|
|
|
|
|
|
|
if (demandAvailable) { |
|
|
|
if (demandAvailable) { |
|
|
|
publisher.changeToDemandState(READING); |
|
|
|
publisher.changeToDemandState(READING); |
|
|
|
} |
|
|
|
} |
|
|
|