From f20f6098151b13bc1f1e5785f5c65997f1df37f8 Mon Sep 17 00:00:00 2001
From: Sreelal TS <heysreelal@gmail.com>
Date: Thu, 12 Sep 2024 12:30:26 +0530
Subject: [PATCH] =?UTF-8?q?=F0=9F=93=87=20Setting=20stream=20controllers?=
 =?UTF-8?q?=20in=20init?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/src/televerse/bot/bot.dart | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/lib/src/televerse/bot/bot.dart b/lib/src/televerse/bot/bot.dart
index 7b13c17..549ff8e 100644
--- a/lib/src/televerse/bot/bot.dart
+++ b/lib/src/televerse/bot/bot.dart
@@ -248,6 +248,17 @@ class Bot<CTX extends Context> {
     } catch (err, st) {
       _handleTheGetMeError(err, st);
     }
+
+    // Set stream controllers
+    if (fetcher._updateStreamController == null ||
+        fetcher._updateStreamController?.isClosed == true) {
+      fetcher._updateStreamController = StreamController<Update>.broadcast();
+    }
+    if (fetcher._updatesStreamController == null ||
+        fetcher._updatesStreamController?.isClosed == true) {
+      fetcher._updatesStreamController =
+          StreamController<List<Update>>.broadcast();
+    }
     // Set instance variable
     _instance = this;
   }
@@ -598,7 +609,6 @@ class Bot<CTX extends Context> {
       await _initializeBot();
     }
 
-    fetcher._updateStreamController = StreamController<Update>.broadcast();
     fetcher._updateSubscription = fetcher.onUpdate().listen(
           _onUpdate,
           onDone: _onStop,