|
|
|
@ -222,7 +222,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
@@ -222,7 +222,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
|
|
|
|
|
NO_DEMAND { |
|
|
|
|
@Override |
|
|
|
|
<T> void request(AbstractListenerReadPublisher<T> publisher, long n) { |
|
|
|
|
if (Operators.checkRequest(n, publisher.subscriber)) { |
|
|
|
|
if (Operators.validate(n)) { |
|
|
|
|
Operators.addAndGet(DEMAND_FIELD_UPDATER, publisher, n); |
|
|
|
|
if (publisher.changeState(this, DEMAND)) { |
|
|
|
|
publisher.checkOnDataAvailable(); |
|
|
|
@ -240,7 +240,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
@@ -240,7 +240,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
|
|
|
|
|
DEMAND { |
|
|
|
|
@Override |
|
|
|
|
<T> void request(AbstractListenerReadPublisher<T> publisher, long n) { |
|
|
|
|
if (Operators.checkRequest(n, publisher.subscriber)) { |
|
|
|
|
if (Operators.validate(n)) { |
|
|
|
|
Operators.addAndGet(DEMAND_FIELD_UPDATER, publisher, n); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
@ -268,7 +268,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
@@ -268,7 +268,7 @@ public abstract class AbstractListenerReadPublisher<T> implements Publisher<T> {
|
|
|
|
|
READING { |
|
|
|
|
@Override |
|
|
|
|
<T> void request(AbstractListenerReadPublisher<T> publisher, long n) { |
|
|
|
|
if (Operators.checkRequest(n, publisher.subscriber)) { |
|
|
|
|
if (Operators.validate(n)) { |
|
|
|
|
Operators.addAndGet(DEMAND_FIELD_UPDATER, publisher, n); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|