AccumulatorStream<E, D> constructor

AccumulatorStream<E, D>(
  1. Iterable<Future<D>> futures,
  2. 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);
  });
}