Add concurrentAsyncExpand (dart-lang/stream_transform#90)
Closes dart-lang/stream_transform#77
Added with the `Merge` extension, since the behavior is similar to
merging streams that are created lazily.
Adds a private `StreamTransformer` to merge a `Stream<Stream<T>>`. This
could be exposed separately as an extension on that type later.
In order to allow cancelling and then re-listening on broadcast streams,
an sub stream which is single subscription must be converted to
broadcast. This can be risky since subscriptions can leak and cause the
inner streams to never be canceled.
5 files changed
tree: 719a56958d16ae96a99cb5b4b1937e3f7bbaf1a7
- pkgs/
