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

Method Recv

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

Recv gets the next completion chunk

()

Source from the content-addressed store, hash-verified

175type MessageStream interface {
176 // Recv gets the next completion chunk
177 Recv() (MessageStreamResponse, error)
178 // Close closes the stream
179 Close()
180}

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