Bugfix
This commit is contained in:
parent
e5f5108c91
commit
59b830b74f
|
@ -700,7 +700,9 @@ public class MonoUtils {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onNext(T t) {
|
public void onNext(T t) {
|
||||||
handler.handle(t);
|
if (handler != null) {
|
||||||
|
handler.handle(t);
|
||||||
|
}
|
||||||
if (!fetchMode.get()) {
|
if (!fetchMode.get()) {
|
||||||
readCoreSubscription.request(1);
|
readCoreSubscription.request(1);
|
||||||
}
|
}
|
||||||
|
@ -713,7 +715,9 @@ public class MonoUtils {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onComplete() {
|
public void onComplete() {
|
||||||
readEndHandler.handle(null);
|
if (readEndHandler != null) {
|
||||||
|
readEndHandler.handle(null);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
return this;
|
return this;
|
||||||
|
|
Loading…
Reference in New Issue