( sakanaStream: AsyncIterable<ChatCompletionChunk>, onComplete?: (content: string, usage: CompletionUsage) => void )
| 7 | * Uses the shared OpenAI-compatible streaming utility. |
| 8 | */ |
| 9 | export function createReadableStreamFromSakanaStream( |
| 10 | sakanaStream: AsyncIterable<ChatCompletionChunk>, |
| 11 | onComplete?: (content: string, usage: CompletionUsage) => void |
| 12 | ): ReadableStream<Uint8Array> { |
| 13 | return createOpenAICompatibleStream(sakanaStream, 'Sakana', onComplete) |
| 14 | } |
no test coverage detected