| commit | 1ef29b6fa84b837be96c1b5a83b7a0e6bc09aabd | [log] [tgz] |
|---|---|---|
| author | Nate Bosch <nbosch1@gmail.com> | Tue Jul 11 10:35:55 2017 -0700 |
| committer | GitHub <noreply@github.com> | Tue Jul 11 10:35:55 2017 -0700 |
| tree | 31e18d0b47c1952b3871c374c937e7de0f6c43ec | |
| parent | 52ecefcaa17ff6cb378dfc7971d5655474a84285 [diff] |
Fix asyncWhere for broadcast streams (dart-lang/stream_transform#33) Previous implementation may have failed to send onDone for some listeners since each listener would increment `valuesWaiting` and only the last listener would decrement it back to zero. There were also potential bugs if the predicate was non-deterministic.