stream_transform
stream_transform copied to clipboard
dart-lang
Dart utility methods to create StreamTransfomer instances to manipulate Streams
Given a stream with events at `t = 0, 1, 2, 5, 6`, is there a way to transform this into a stream where each event adds a 2 second...
# Description When using the [startWith](https://pub.dev/documentation/stream_transform/latest/stream_transform/Concatenate/startWith.html) operator on a broadcast source stream, the events emitted by the source stream are ignored/dropped until `Future.value(initialValue)` completes. # Reproduction E.g. the following code...
Allow combineLastestAll output stream to emit events even if all the input streams don't have emitted yet.
It's more a feature request than an issue. I'm facing this issue: https://stackoverflow.com/questions/68590198/dart-get-the-last-or-the-first-value-of-a-stream There is a suggestion to solve it (see bellow), and I would love to see it inside...
Consider a stream that does something when being listened to: ```dart import 'dart:async'; import 'package:stream_transform/stream_transform.dart'; class DoOnSubscribeStream extends Stream { final Stream inner; final void Function() onSubscribe; DoOnSubscribeStream(this.inner, this.onSubscribe); @override...
Hello folks. Seeing that this package could potentially be merged into `package:async`, got me thinking about what features it lacks for my personal usage to completely replace the RxDart package....
We should consider merging this into https://pub.dev/packages/async cc @natebosch
Hello folks, Currently `transformFromHandlers` isn't exported in `lib/stream_transform.dart`. Is it possible to expose it? It's better than the standard `fromHandlers` transformer in the sense that it allows relying on a...
If one wants to combine a list of streams that may be also empty or only contains one stream, the solution would be to do this over and over: ```dart...
For non-broadcast streams this would implicitly call `.asBroadcastStream()`. For any new listeners on a Stream the most recently emitted event will always be emitted. This one might not _quite_ be...
