Function decode_async 

pub fn decode_async<'a, D, S, Src, C>(
    decoder: D,
    sink: S,
    source: &'a mut Src,
    compute: C,
    opts: DriveOptions,
    pulse: Option<SharedPulse>,
) -> impl Future<Output = Result<(OutputInfo, S), AsyncDriveError<D::Error>>> + Send + 'a
where
    D: IncrementalDecode + Send + 'static,
    S: DecodeRowSink + Send + 'static,
    Src: AsyncSource + ?Sized,
    C: Compute + 'a,

Decode from an async source with no thread blocked on I/O. See the module documentation.

Returns the output info and the sink. pulse cancels at the next step inside a batch and between batches, and receives the row total and per-strip progress.