diff --git a/CHANGELOG.md b/CHANGELOG.md index d898082..52dda07 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,3 +1,9 @@ +# 0.13.6 + +## Fix + +- Verbose logger listener steam already listened to + # 0.13.5 ## Fix diff --git a/lib/src/core/util/input_listener/force_quit_listener.dart b/lib/src/core/util/input_listener/force_quit_listener.dart index ee21bab..b055c2a 100644 --- a/lib/src/core/util/input_listener/force_quit_listener.dart +++ b/lib/src/core/util/input_listener/force_quit_listener.dart @@ -17,7 +17,8 @@ class ForceQuitListener { _listeners.remove(listener); static void init() { - _subscription = ProcessSignal.sigint.watch().listen((signal) async { + _subscription = + ProcessSignal.sigint.watch().asBroadcastStream().listen((signal) async { if (_isShuttingDown) return; _isShuttingDown = true; ImpaktfullCliLogger.log('\nForce quit detected. Cleaning up...'); diff --git a/lib/src/core/util/input_listener/versbose_logging_listener.dart b/lib/src/core/util/input_listener/versbose_logging_listener.dart index 1cc01db..421a4be 100644 --- a/lib/src/core/util/input_listener/versbose_logging_listener.dart +++ b/lib/src/core/util/input_listener/versbose_logging_listener.dart @@ -10,7 +10,7 @@ class VerboseLoggingListener { static void startInputListener() { _subscription?.cancel(); - _subscription = stdin.listen((data) { + _subscription = stdin.asBroadcastStream().listen((data) { final input = String.fromCharCodes(data).trim(); if (input.toLowerCase() == 'v' || input.toLowerCase() == 'verbose') {