diff --git a/CHANGELOG.md b/CHANGELOG.md
index 4675114..f247608 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,3 +1,7 @@
+## 2.4.2
+
+* `StreamQueue` starts listening immediately to broadcast strings.
+
 ## 2.4.1
 
 * Deprecate `DelegatingStream.typed`. Use `Stream.cast` instead.
diff --git a/lib/src/stream_queue.dart b/lib/src/stream_queue.dart
index 97d74c7..278e249 100644
--- a/lib/src/stream_queue.dart
+++ b/lib/src/stream_queue.dart
@@ -118,7 +118,13 @@
   factory StreamQueue(Stream<T> source) => StreamQueue._(source);
 
   // Private generative constructor to avoid subclasses.
-  StreamQueue._(this._source);
+  StreamQueue._(this._source) {
+    // Start listening immediately if we could otherwise lose events.
+    if (_source.isBroadcast) {
+      _ensureListening();
+      _pause();
+    }
+  }
 
   /// Asks if the stream has any more events.
   ///
diff --git a/pubspec.yaml b/pubspec.yaml
index 599ccdd..0cb71cf 100644
--- a/pubspec.yaml
+++ b/pubspec.yaml
@@ -1,5 +1,5 @@
 name: async
-version: 2.4.1
+version: 2.4.2
 
 description: Utility functions and classes related to the 'dart:async' library.
 homepage: https://www.github.com/dart-lang/async