MCPcopy Create free account
hub / github.com/astercloud/aster / Stream

Method Stream

pkg/agent/streaming.go:46–46  ·  view source on GitHub ↗

Stream 流式执行,返回事件流 相比 Chat 方法的优势: 1. 内存高效 - 按需生成事件,无需完整加载到内存 2. 背压控制 - 客户端可控制消费速度 3. 实时响应 - 可以立即处理每个事件,而不是等待所有事件 4. 多消费者 - 支持 Copy 复制流给多个消费者

(ctx context.Context, message string, opts ...Option)

Source from the content-addressed store, hash-verified

44 // 3. 实时响应 - 可以立即处理每个事件,而不是等待所有事件
45 // 4. 多消费者 - 支持 Copy 复制流给多个消费者
46 Stream(ctx context.Context, message string, opts ...Option) *stream.Reader[*session.Event]
47}
48
49// Stream 实现流式执行接口

Callers 4

runModelStepStreamingMethod · 0.65
StreamMethod · 0.65
handleStreamMethod · 0.65
runModelStepMethod · 0.65

Implementers 14

MockSummaryProviderpkg/memory/session_summary_test.go
MockProviderWithErrorpkg/memory/session_summary_test.go
MockProviderpkg/evals/llm_scorer_test.go
GLMProviderpkg/provider/glm.go
GeminiProviderpkg/provider/gemini.go
AnthropicProviderpkg/provider/anthropic.go
CustomClaudeProviderpkg/provider/custom_claude.go
DeepseekProviderpkg/provider/deepseek.go
GatewayProviderpkg/provider/gateway.go
OpenAICompatibleProviderpkg/provider/openai_compatible.go
Agentpkg/agent/agent.go
ModelFallbackManagerpkg/agent/model_fallback.go

Calls

no outgoing calls

Tested by

no test coverage detected