Stream asyncMapSample()

in lib/src/async_map.dart [66:72]

• 6 lines of code
• 1 McCabe index (conditional complexity)

  Stream<S> asyncMapSample<S>(Future<S> Function(T) convert) {
    var workFinished = StreamController<void>()
      // Let the first event through.
      ..add(null);
    return aggregateSample(workFinished.stream, _dropPrevious)
        ._asyncMapThen(convert, workFinished.add);
  }