Release 2.2.9

Release 2.2.9

Author: mikolak

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 2.2.9
+
+* Fixed issue with incorrectly typed Stream
+
 ## 2.2.8
 
 * Formatted all sources according to dartfmt for consistency

android/build.gradle

@@ -1,5 +1,5 @@
 group 'com.polidea.flutter_ble_lib'
-version '2.2.8'
+version '2.2.9'
 
 buildscript {
     repositories {

ios/flutter_ble_lib.podspec

@@ -3,7 +3,7 @@
 #
 Pod::Spec.new do |s|
   s.name             = 'flutter_ble_lib'
-  s.version          = '2.2.8'
+  s.version          = '2.2.9'
   s.summary          = 'A new flutter plugin project.'
   s.description      = <<-DESC
 A new flutter plugin project.

lib/src/bridge/device_connection_mixin.dart

@@ -25,7 +25,7 @@ mixin DeviceConnectionMixin on FlutterBLE {
 
   Stream<PeripheralConnectionState> observePeripheralConnectionState(
       String identifier, bool emitCurrentValue) {
-    var controller = StreamController<String>(
+    var controller = StreamController<PeripheralConnectionState>(
       onListen: () => _methodChannel.invokeMethod(
         MethodName.observeConnectionState,
         <String, dynamic>{
@@ -37,18 +37,15 @@ mixin DeviceConnectionMixin on FlutterBLE {
       ),
     );
 
-    controller
-        .addStream(_peripheralConnectionStateChanges)
-        .then((value) => controller?.close());
-
-    return controller.stream
-        .map((jsonString) =>
-            ConnectionStateContainer.fromJson(jsonDecode(jsonString)))
-        .where((connectionStateContainer) =>
-            connectionStateContainer.peripheralIdentifier == identifier)
-        .map((connectionStateContainer) =>
-            connectionStateContainer.connectionState)
-        .map((connectionStateString) {
+    var sourceStream =
+        _peripheralConnectionStateChanges
+            .map((jsonString) =>
+                ConnectionStateContainer.fromJson(jsonDecode(jsonString)))
+            .where((connectionStateContainer) =>
+                connectionStateContainer.peripheralIdentifier == identifier)
+            .map((connectionStateContainer) =>
+                connectionStateContainer.connectionState)
+            .map((connectionStateString) {
       switch (connectionStateString.toLowerCase()) {
         case NativeConnectionState.connected:
           return PeripheralConnectionState.connected;
@@ -64,6 +61,15 @@ mixin DeviceConnectionMixin on FlutterBLE {
           );
       }
     });
+
+    controller
+        .addStream(
+          sourceStream,
+          cancelOnError: true,
+        )
+        .then((value) => controller?.close());
+
+    return controller.stream;
   }
 
   Future<bool> isPeripheralConnected(String peripheralIdentifier) async {

pubspec.yaml

@@ -1,6 +1,6 @@
 name: flutter_ble_lib
 description: FlutterBle Library is a flutter library that supports BLE operations. It uses MultiPlatformBleAdapter as a native backend..
-version: 2.2.8
+version: 2.2.9
 homepage: https://github.com/Polidea/FlutterBleLib
 
 environment: