stream.default.PipelineSourceArgument

type PipelineSourceArgument<T> = T extends (...args: any[]) => infer R ? R : T extends infer S ? S extends web.TransformStream<any, infer O> ? web.ReadableStream<O> : S : never