diff --git a/src/main/java/it/tdlight/utils/MonoUtils.java b/src/main/java/it/tdlight/utils/MonoUtils.java index e1c6271..3140f30 100644 --- a/src/main/java/it/tdlight/utils/MonoUtils.java +++ b/src/main/java/it/tdlight/utils/MonoUtils.java @@ -700,7 +700,9 @@ public class MonoUtils { @Override public void onNext(T t) { - handler.handle(t); + if (handler != null) { + handler.handle(t); + } if (!fetchMode.get()) { readCoreSubscription.request(1); } @@ -713,7 +715,9 @@ public class MonoUtils { @Override public void onComplete() { - readEndHandler.handle(null); + if (readEndHandler != null) { + readEndHandler.handle(null); + } } }); return this;