From d78d6a5a47e3893c382f8083db714c787899e4a4 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Wed, 13 Jan 2021 23:03:04 +0100
Subject: [PATCH] Update EventBusFlux.java

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

diff --git a/src/main/java/it/tdlight/tdlibsession/EventBusFlux.java b/src/main/java/it/tdlight/tdlibsession/EventBusFlux.java
index f005afe..805f586 100644
--- a/src/main/java/it/tdlight/tdlibsession/EventBusFlux.java
+++ b/src/main/java/it/tdlight/tdlibsession/EventBusFlux.java
@@ -70,23 +70,27 @@ public class EventBusFlux {
 										});
 									}, error -> {
 										eventBus.request(subscriptionAddress + ".signal", SignalMessage.<T>onError(error), signalDeliveryOptions, msg2 -> {
+											logger.info("Errored flux \"" + fluxAddress + "\"");
 											if (msg2.failed()) {
-												logger.error("Failed to send onNext signal", msg2.cause());
+												logger.error("Failed to send onError signal", msg2.cause());
 											}
 										});
 									}, () -> {
 										eventBus.request(subscriptionAddress + ".signal", SignalMessage.<T>onComplete(), signalDeliveryOptions, msg2 -> {
+											logger.info("Completed flux \"" + fluxAddress + "\"");
 											if (msg2.failed()) {
-												logger.error("Failed to send onNext signal", msg2.cause());
+												logger.error("Failed to send onComplete signal", msg2.cause());
 											}
 										});
 									});
 
 									cancel.handler(msg3 -> {
+										logger.warn("Cancelling flux \"" + fluxAddress + "\"");
 										subscription.dispose();
 										msg3.reply(EMPTY, deliveryOptions);
 									});
 									dispose.handler(msg2 -> {
+										logger.warn("Disposing flux \"" + fluxAddress + "\"");
 										subscription.dispose();
 										cancel.unregister(v -> {
 											if (v.failed()) {