Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
I forgot to actually push these to the pull request.
  • Loading branch information
nex3 authored May 4, 2021
1 parent 67ae670 commit 1d45068
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 3 deletions.
4 changes: 4 additions & 0 deletions pkgs/async/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,7 @@
## 2.6.2

* Internal changes only.

## 2.6.1

* When `StreamGroup.stream.listen()` is called, gracefully handle component
Expand Down
4 changes: 2 additions & 2 deletions pkgs/async/lib/src/stream_group.dart
Original file line number Diff line number Diff line change
Expand Up @@ -188,7 +188,7 @@ class StreamGroup<T> implements Sink<Stream<T>> {
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.
Expand Down Expand Up @@ -232,8 +232,8 @@ class StreamGroup<T> implements Sink<Stream<T>> {
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;
Expand Down
2 changes: 1 addition & 1 deletion pkgs/async/pubspec.yaml
Original file line number Diff line number Diff line change
@@ -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
Expand Down

0 comments on commit 1d45068

Please sign in to comment.