AccumulatorStream<E, D> constructor
AccumulatorStream<E, D> (
- Iterable<
Future< futures,D> > - ConversionCallback<
E, D> _convert
Implementation
AccumulatorStream(
Iterable<Future<D>> futures,
this._convert,
) {
Stream.fromFutures(futures).listen((D data) {
_elements.add(_convert(data));
}, onDone: () {
_controller.add(_elements);
_controller.close();
}, onError: (error, trace) {
_controller.addError(error, trace);
});
}