ComputeStreamTransformer<TInput, TOutput> constructor

ComputeStreamTransformer<TInput, TOutput>({
  1. required ComputeCallback<TInput, TOutput> computeFunction,
  2. TOutput onError(
    1. Object error,
    2. StackTrace stackTrace
    )?,
})

Creates a transformer that runs computeFunction on a background isolate for each event, optionally recovering compute failures via onError. Audited: 2026-06-12 11:26 EDT

Implementation

ComputeStreamTransformer({required this.computeFunction, this.onError});