MCPcopy
hub / github.com/docker/docker-agent / MessageStream

Interface MessageStream

pkg/chat/chat.go:175–180  ·  view source on GitHub ↗

MessageStream interface represents a stream of chat completions

Source from the content-addressed store, hash-verified

173
174// MessageStream interface represents a stream of chat completions
175type MessageStream interface {
176 // Recv gets the next completion chunk
177 Recv() (MessageStreamResponse, error)
178 // Close closes the stream
179 Close()
180}
181
182// DetectMimeType returns the MIME type for a file by reading its first 512
183// bytes and inspecting the content (magic bytes). For text-based files that

Callers 16

drainStreamFunction · 0.65
RecvMethod · 0.65
lockFileFunction · 0.65
writeJSONFunction · 0.65
syncDirFunction · 0.65
writeTempFileFunction · 0.65

Implementers 14

mockStreampkg/sessiontitle/generator_test.go
fakeStreampkg/telemetry/genai/genai_test.go
errorStreampkg/telemetry/genai/genai_test.go
instrumentedStreampkg/telemetry/genai/stream.go
StreamAdapterpkg/model/provider/gemini/adapter.go
streamAdapterpkg/model/provider/bedrock/adapter.go
betaStreamAdapterpkg/model/provider/anthropic/beta_adap
streamAdapterpkg/model/provider/anthropic/adapter.g
ResponseStreamAdapterpkg/model/provider/openai/response_str
StreamAdapterpkg/model/provider/oaistream/adapter.g
mockStreampkg/runtime/runtime_test.go
blockingStreampkg/runtime/turn_end_test.go

Calls

no outgoing calls

Tested by

no test coverage detected