MCPcopy Index your code
hub / github.com/coder/coder / OpenAIStreamingResponse

Function OpenAIStreamingResponse

coderd/x/chatd/chattest/openai.go:833–842  ·  view source on GitHub ↗

OpenAIStreamingResponse creates a streaming response from chunks.

(chunks ...OpenAIChunk)

Source from the content-addressed store, hash-verified

831
832// OpenAIStreamingResponse creates a streaming response from chunks.
833func 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.
845func OpenAINonStreamingResponse(text string) OpenAIResponse {

Calls

no outgoing calls