OpenAIStreamingResponse creates a streaming response from chunks.
(chunks ...OpenAIChunk)
| 831 | |
| 832 | // OpenAIStreamingResponse creates a streaming response from chunks. |
| 833 | func OpenAIStreamingResponse(chunks ...OpenAIChunk) OpenAIResponse { |
| 834 | ch := make(chan OpenAIChunk, len(chunks)) |
| 835 | go func() { |
| 836 | for _, chunk := range chunks { |
| 837 | ch <- chunk |
| 838 | } |
| 839 | close(ch) |
| 840 | }() |
| 841 | return OpenAIResponse{StreamingChunks: ch} |
| 842 | } |
| 843 | |
| 844 | // OpenAINonStreamingResponse creates a non-streaming response with the given text. |
| 845 | func OpenAINonStreamingResponse(text string) OpenAIResponse { |
no outgoing calls