diff --git a/lib/src/models/devices/open_earable_factory.dart b/lib/src/models/devices/open_earable_factory.dart index 8b226df..f955111 100644 --- 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 _createSingleDataSubscription(String componentName) { - StreamController streamController = StreamController(); + StreamController 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 index d24b9c1..54cb8a3 100644 --- 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 } } } -