From 59b830b74f724012384f825a9bd0756977cfc9c7 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Wed, 16 Jun 2021 23:51:14 +0200
Subject: [PATCH] Bugfix

---
 src/main/java/it/tdlight/utils/MonoUtils.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

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;