| 5020 | * @returns {Promise<any>} Streaming generator | 5020 | * @returns {Promise<any>} Streaming generator |
| 5021 | */ | 5021 | */ |
| 5022 | async function sendStreamingRequest(type, data) { | 5022 | async function sendStreamingRequest(type, data) { |
| | 5023 | if (abortController?.signal?.aborted) { |
| | 5024 | throw new Error('Generation was aborted.'); |
| | 5025 | } |
| | 5026 | |
| 5023 | switch (main_api) { | 5027 | switch (main_api) { |
| 5024 | case 'openai': | 5028 | case 'openai': |
| 5025 | return await sendOpenAIRequest(type, data.prompt, streamingProcessor.abortController.signal); | 5029 | return await sendOpenAIRequest(type, data.prompt, streamingProcessor.abortController.signal); |