This repository has been archived by the owner on Oct 17, 2024. It is now read-only.
Tags: dart-archive/async
Tags
Add `StreamExtensions.listenAndBuffer()` (#235) The immediate motivation for this is to buffer stderr from a subprocess until we learn whether the subprocess completed successfully or not. It's important to consume the output eagerly so the process doesn't deadlock after saturating the OS and/or `dart:io` buffers, but we don't want to print it at all if the process completes successfully.
Fix a StreamGroup bug when a component stream's listen() throws (#173) This would put the StreamGroup into an inconsistent state where it would believe itself to be active, but only some streams would have subscriptions. This was exacerbated by dart-lang/sdk#45815, which meant that even though _onListen threw an error a StreamSubscription was created and returned, so further callbacks could still be called. Now instead of going into an inconsistent state, the StreamGroup simply cancels itself.
PreviousNext