Skip to content
This repository has been archived by the owner on Oct 17, 2024. It is now read-only.

Fix broadcast StreamGroup ignores streams added after StreamGroup is canceled #184

Conversation

anhtuan23
Copy link
Contributor

@google-cla google-cla bot added the cla: yes label Jun 13, 2021
@google-cla
Copy link

google-cla bot commented Jul 20, 2021

All (the pull request submitter and all commit authors) CLAs are signed, but one or more commits were authored or co-authored by someone other than the pull request submitter.

We need to confirm that all authors are ok with their commits being contributed to this project. Please have them confirm that by leaving a comment that contains only @googlebot I consent. in this pull request.

Note to project maintainer: There may be cases where the author cannot leave a comment, or the comment is not properly detected as consent. In those cases, you can manually confirm consent of the commit author(s), and set the cla label to yes (if enabled on your project).

ℹ️ Googlers: Go here for more info.

@google-cla google-cla bot added cla: no and removed cla: yes labels Jul 20, 2021
@natebosch
Copy link
Contributor

@googlebot I consent.

@natebosch natebosch requested a review from jakemac53 July 20, 2021 18:45
@kevmoo
Copy link
Contributor

kevmoo commented Jul 20, 2021

Great find and fix, @anhtuan23 !!

@natebosch natebosch merged commit 25a7e2e into dart-archive:master Jul 20, 2021
mosuem pushed a commit to dart-lang/core that referenced this pull request Oct 14, 2024
…-archive/async#184)

In a broadcast `StreamGroup` when all listeners have canceled the inner
subscriptions are kept only for single subscriber streams. When a new
listener is added and subscriptions need to be recreated for inner
broadcast streams the presence of a single subscriber subscription in
the collection of subscriptions would cause the listen to bail out early
and fail to subscribe to later broadcast streams. Change `return` to
`continue` to keep going with the rest of the streams.
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
Development

Successfully merging this pull request may close these issues.

Broadcast StreamGroup doesn't listen to later added streams after _onCancelBroadcast is called
4 participants