Type Alias PipelineTransform<S, U>

PipelineTransform:
    | ReadWriteStream
    | (
        (
            source: S extends (
                ...args: any[],
            ) => Iterable<infer ST> | AsyncIterable<infer ST>
                ? AsyncIterable<ST>
                : S,
        ) => AsyncIterable<U>
    )