|
|
import { resolveProvider } from "../../lib/getInferenceProviderMapping.js"; |
|
|
import { getProviderHelper } from "../../lib/getProviderHelper.js"; |
|
|
import type { InferenceTask, Options, RequestArgs } from "../../types.js"; |
|
|
import { innerStreamingRequest } from "../../utils/request.js"; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
export async function* streamingRequest<T>( |
|
|
args: RequestArgs, |
|
|
options?: Options & { |
|
|
|
|
|
task?: InferenceTask; |
|
|
} |
|
|
): AsyncGenerator<T> { |
|
|
console.warn( |
|
|
"The streamingRequest method is deprecated and will be removed in a future version of huggingface.js. Use specific task functions instead." |
|
|
); |
|
|
const provider = await resolveProvider(args.provider, args.model, args.endpointUrl); |
|
|
const providerHelper = getProviderHelper(provider, options?.task); |
|
|
yield* innerStreamingRequest(args, providerHelper, options); |
|
|
} |
|
|
|