⚠️ Internal: This API is not publically exported by the package.

Type alias PipelineTransform<S, U>

PipelineTransform<S, U>: ReadWriteStream | ((source) => AsyncIterable<U>)

Type Parameters

Type declaration

    • (source): AsyncIterable<U>
    • Parameters

      • source: S extends ((...args) => Iterable<infer ST> | AsyncIterable<infer ST>)
            ? AsyncIterable<ST>
            : S

      Returns AsyncIterable<U>