Rewrite concat (dart-lang/stream_transform#32)
Uses sync forwarders for dart-lang/stream_transform#24
The simple implementation leaves out a lot of edge cases around
single-subscription vs broadcast streams and how they combine. Rewrite
to handle pause, resume, and cancel manually.
- Loop over stream types in tests
- Add test for onDone and canceling and relistening
- Force _next to broadcast when first is broadcast
- Document behavior of broadcast stream as second stream
- Add tests for pause/resume
3 files changed
tree: 501dfc85423329593fcd1ea18ff1c72eeebe2069
- pkgs/