StreamAdapter adapts the OpenAI stream to our interface
| 17 | |
| 18 | // StreamAdapter adapts the OpenAI stream to our interface |
| 19 | type StreamAdapter struct { |
| 20 | stream *ssestream.Stream[openai.ChatCompletionChunk] |
| 21 | lastFinishReason chat.FinishReason |
| 22 | toolCalls map[int]string |
| 23 | trackUsage bool |
| 24 | } |
| 25 | |
| 26 | func NewStreamAdapter(stream *ssestream.Stream[openai.ChatCompletionChunk], trackUsage bool) *StreamAdapter { |
| 27 | return &StreamAdapter{ |
nothing calls this directly
no outgoing calls
no test coverage detected