asyncMap<R> method

OffsetIterator<R> asyncMap<R>(
  1. Future<R> pred(
    1. T
    ), {
  2. String name = 'asyncMap',
  3. SeedCallback<R>? seed,
  4. int retention = 0,
  5. int concurrency = 1,
  6. bool? cancelOnError,
  7. bool bubbleCancellation = true,
})

Implementation

OffsetIterator<R> asyncMap<R>(
  Future<R> Function(T) pred, {
  String name = 'asyncMap',
  SeedCallback<R>? seed,
  int retention = 0,
  int concurrency = 1,
  bool? cancelOnError,
  bool bubbleCancellation = true,
}) =>
    transform(
      (item) => pred(item).then((v) => [v]),
      name: name,
      seed: seed,
      retention: retention,
      concurrency: concurrency,
      bubbleCancellation: bubbleCancellation,
      cancelOnError: cancelOnError,
    );