Code review changes for #173 (#174)
I forgot to actually push these to the pull request.
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 6dff198..1560001 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,3 +1,7 @@
+## 2.6.2
+
+* Internal changes only.
+
## 2.6.1
* When `StreamGroup.stream.listen()` is called, gracefully handle component
diff --git a/lib/src/stream_group.dart b/lib/src/stream_group.dart
index 6270d9a..f7819bf 100644
--- a/lib/src/stream_group.dart
+++ b/lib/src/stream_group.dart
@@ -188,7 +188,7 @@
void _onListen() {
_state = _StreamGroupState.listening;
- for (var entry in _subscriptions.entries.toList()) {
+ for (var entry in [..._subscriptions.entries]) {
// If this is a broadcast group and this isn't the first time it's been
// listened to, there may still be some subscriptions to
// single-subscription streams.
@@ -232,8 +232,8 @@
var futures = _subscriptions.entries
.map((entry) {
var subscription = entry.value;
- if (subscription != null) return subscription.cancel();
try {
+ if (subscription != null) return subscription.cancel();
return entry.key.listen(null).cancel();
} catch (_) {
return null;
diff --git a/pubspec.yaml b/pubspec.yaml
index 6d5a06d..4fc5b92 100644
--- a/pubspec.yaml
+++ b/pubspec.yaml
@@ -1,5 +1,5 @@
name: async
-version: 2.6.1
+version: 2.6.2-dev
description: Utility functions and classes related to the 'dart:async' library.
repository: https://github.com/dart-lang/async
