use a broadcast stream controller

OpenEarable · Jan 20, 2025 · 7d2b1b5 · 7d2b1b5
1 parent a3d2c29
commit 7d2b1b5
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/lib/src/models/devices/open_earable_factory.dart b/lib/src/models/devices/open_earable_factory.dart
@@ -283,7 +283,7 @@ class _OpenEarableSensor extends Sensor {
   }
 
   Stream<SensorValue> _createSingleDataSubscription(String componentName) {
-    StreamController<SensorValue> streamController = StreamController();
+    StreamController<SensorValue> streamController = StreamController.broadcast();
 
     _dataSubscription?.cancel();
     _dataSubscription = _sensorManager.subscribeToSensorData(_sensorId).listen((data) {

diff --git a/lib/src/models/devices/open_earable_v2.dart b/lib/src/models/devices/open_earable_v2.dart
@@ -332,4 +332,3 @@ class OpenEarableV2 extends Wearable
     }
   }
 }
-
Original file line number	Diff line number	Diff line change
Expand Up		@@ -332,4 +332,3 @@ class OpenEarableV2 extends Wearable
		}
		}
		}