asyncMap<E> method

LxStream<E> asyncMap<E>(
  1. FutureOr<E> convert(
    1. T event
    )
)

Asynchronously transforms each data event.

Implementation

LxStream<E> asyncMap<E>(FutureOr<E> Function(T event) convert) {
  return LxStream<E>.defer(() => valueStream.asyncMap(convert));
}