Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
175
type
MessageStream
interface
{
176
// Recv gets the next completion chunk
177
Recv() (MessageStreamResponse, error)
178
// Close closes the stream
179
Close()
180
}
Callers
15
drainStream
Function · 0.65
TestStartChatAndWrapStream
Function · 0.65
TestWrapStream_ErrorBeforeFinishReason
Function · 0.65
TestWrapStream_ErrorAfterFinishReason
Function · 0.65
TestWrapStream_FinishReasonAndErrorSameRecv
Function · 0.65
Recv
Method · 0.65
TestCustomProvider_ResponsesAPIType
Function · 0.65
TestCustomProvider_ChatCompletionsAPIType
Function · 0.65
drainStream
Function · 0.65
collectStreamContent
Function · 0.65
TestNewClient_TransportWrapperInvokedDirectPath
Function · 0.65
TestNewClient_TransportWrapperInvokedGatewayPath
Function · 0.65
Implementers
14
mockStream
pkg/sessiontitle/generator_test.go
fakeStream
pkg/telemetry/genai/genai_test.go
errorStream
pkg/telemetry/genai/genai_test.go
instrumentedStream
pkg/telemetry/genai/stream.go
StreamAdapter
pkg/model/provider/gemini/adapter.go
streamAdapter
pkg/model/provider/bedrock/adapter.go
betaStreamAdapter
pkg/model/provider/anthropic/beta_adap
streamAdapter
pkg/model/provider/anthropic/adapter.g
ResponseStreamAdapter
pkg/model/provider/openai/response_str
StreamAdapter
pkg/model/provider/oaistream/adapter.g
mockStream
pkg/runtime/runtime_test.go
blockingStream
pkg/runtime/turn_end_test.go
Calls
no outgoing calls
Tested by
15
TestStartChatAndWrapStream
Function · 0.52
TestWrapStream_ErrorBeforeFinishReason
Function · 0.52
TestWrapStream_ErrorAfterFinishReason
Function · 0.52
TestWrapStream_FinishReasonAndErrorSameRecv
Function · 0.52
TestCustomProvider_ResponsesAPIType
Function · 0.52
TestCustomProvider_ChatCompletionsAPIType
Function · 0.52
drainStream
Function · 0.52
collectStreamContent
Function · 0.52
TestNewClient_TransportWrapperInvokedDirectPath
Function · 0.52
TestNewClient_TransportWrapperInvokedGatewayPath
Function · 0.52
TestNewClient_TransportWrapperVertexAIFallsBackToGeminiAPI
Function · 0.52
TestParallelToolCallIDsAreNotCrossWired
Function · 0.52