PubNub SDK v1.1.3 release.

.pubnub.yml

@@ -1,5 +1,15 @@
 ---
 changelog:
+  -
+    changes:
+      -
+        text: "Fixes unsubscribeAll so its no longer modifying subscription list during iteration."
+        type: bug
+      -
+        text: "Fixes exports to include presence and channel group results."
+        type: bug
+    date: May 11, 20
+    version: v1.1.3
   -
     changes:
       -
@@ -195,4 +205,4 @@ supported-platforms:
     platforms:
       - "Dart SDK >=2.6.0 <3.0.0"
     version: "PubNub Dart SDK"
-version: "1.1.2"
+version: "1.1.3"

CHANGELOG.md

@@ -1,3 +1,11 @@
+## [v1.1.3](https://github.com/pubnub/dart/releases/tag/v1.1.3)
+May 11 2020
+
+[Full Changelog](https://github.com/pubnub/dart/compare/v1.1.2...v1.1.3)
+
+- 🐛 Fixes unsubscribeAll so its no longer modifying subscription list during iteration. Fixed the following issues reported by [@pushpendraKh](https://github.com/pushpendraKh): [#6](https://github.com/pubnub/dart/issues/6).
+- 🐛 Fixes exports to include presence and channel group results. 
+
 ## [v1.1.2](https://github.com/pubnub/dart/releases/tag/v1.1.2)
 May 6 2020
 

lib/pubnub.dart

@@ -10,7 +10,12 @@ export './src/dx/channel/channel_group.dart' show ChannelGroup;
 
 export './src/dx/_endpoints/publish.dart' show PublishResult;
 export './src/dx/_endpoints/presence.dart'
-    show HeartbeatResult, LeaveResult, StateInfo;
+    show HeartbeatResult, LeaveResult, HereNowResult, StateInfo;
+export './src/dx/_endpoints/channel_group.dart'
+    show
+        ChannelGroupChangeChannelsResult,
+        ChannelGroupListChannelsResult,
+        ChannelGroupDeleteResult;
 export './src/dx/_endpoints/signal.dart' show SignalResult;
 export './src/dx/_endpoints/push.dart'
     show

lib/src/core/core.dart

@@ -20,7 +20,7 @@ class Core {
   NetworkModule networking;
   ParserModule parser;
 
-  static String version = '1.1.2';
+  static String version = '1.1.3';
 
   Core(
       {Keyset defaultKeyset,

lib/src/core/keyset.dart

@@ -11,6 +11,9 @@ class KeysetStore {
   final Map<String, Keyset> _store = {};
   String _defaultName;
 
+  /// Returns a list of all keysets in this store
+  List<Keyset> get keysets => _store.values.toList();
+
   /// Adds a [keyset] named [name] to the store.
   ///
   /// If [useAsDefault] is true, then it will be used as a default keyset.
@@ -73,7 +76,9 @@ class KeysetStore {
 
   /// Iterate over each keyset.
   void forEach(void Function(String, Keyset) callback) {
-    _store.forEach(callback);
+    for (var entry in _store.entries) {
+      callback(entry.key, entry.value);
+    }
   }
 
   Keyset _getDefault({bool throwOnNull}) {

lib/src/dx/subscribe/envelope.dart

@@ -35,8 +35,6 @@ class Envelope {
   dynamic userMeta;
   dynamic originalMessage;
 
-  Envelope._();
-
   Envelope.fromJson(dynamic object) {
     shard = object['a'] as String;
     subscriptionPattern = object['b'] as String;

lib/src/dx/subscribe/manager/manager.dart

@@ -59,7 +59,7 @@ class SubscriptionManager {
         ctx.update(ctx.payload);
       })
       ..when('state.idle', 'enters').callback((ctx) {
-        _logger.info(
+        _logger.silly(
             'Entering ${ctx.entering} from ${ctx.exiting} because of ${ctx.event}');
 
         if (ctx.event == 'update') {
@@ -71,13 +71,13 @@ class SubscriptionManager {
           if ((newContext['channels'].length > 0 ||
               newContext['channelGroups'].length > 0)) {
             if (_messagesController == null || _messagesController.isClosed) {
-              _logger.info('Creating the controller...');
+              _logger.silly('Creating the controller...');
               _messagesController = StreamController.broadcast();
             }
             ctx.machine.send('fetch');
           } else {
             if (_messagesController != null) {
-              _logger.info('Disposing the controller...');
+              _logger.silly('Disposing the controller...');
               _messagesController.close();
               _messagesController = null;
             }
@@ -90,7 +90,7 @@ class SubscriptionManager {
     _SubscriptionMachine
       ..when('state.fetching').machine('request', _RequestMachine,
           onBuild: (m, sm) {
-        _logger.info('Entering state.fetching');
+        _logger.silly('Entering state.fetching');
         var params = SubscribeParams(keyset, m.context['timetoken'].value,
             region: m.context['region'],
             channels: m.context['channels'],

lib/src/dx/subscribe/subscribe.dart

@@ -49,11 +49,11 @@ mixin SubscribeDx on Core {
 
   /// Unsubscribes from all channels and channel groups.
   void unsubscribeAll() async {
-    super.keysets.forEach((key, value) async {
-      for (var sub in value.subscriptions) {
+    for (var keyset in keysets.keysets) {
+      for (var sub in [...keyset.subscriptions]) {
         await sub.unsubscribe();
       }
-    });
+    }
   }
 
   /// Announce in [channels] and [channelGroups] that a device linked to the UUID in the keyset left.

lib/src/dx/subscribe/subscription.dart

@@ -112,6 +112,8 @@ class Subscription extends Disposable {
       await _streamSubscription.cancel();
 
       _streamSubscription = null;
+    } else {
+      _logger.warning('Tried unsubscribing from an inactive stream...');
     }
   }
 

pubspec.yaml

@@ -1,6 +1,6 @@
 name: pubnub
 description: PubNub SDK v5 for Dart lang (with Flutter support) that allows you to create real-time applications
-version: 1.1.2
+version: 1.1.3
 homepage: https://www.pubnub.com/docs
 
 environment: