Struct ResponseStreamAdapter

pkg/model/provider/openai/response_stream.go:21–27

ResponseStreamAdapter adapts the OpenAI responses stream to our interface. It works with any responseEventStream implementation (SSE or WebSocket).

// ResponseStreamAdapter adapts the OpenAI responses stream to our interface.
// It works with any responseEventStream implementation (SSE or WebSocket).
type ResponseStreamAdapter struct {
	stream         responseEventStream
	trackUsage     bool
	itemCallIDMap  map[string]string
	itemHasContent map[string]bool
	pendingArgs    map[string]string
}

func newResponseStreamAdapter(stream responseEventStream, trackUsage bool) *ResponseStreamAdapter {
	return &ResponseStreamAdapter{