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

Method Stream

pkg/provider/interface.go:237–237  ·  view source on GitHub ↗

Stream 流式对话

(ctx context.Context, messages []types.Message, opts *StreamOptions)

Source from the content-addressed store, hash-verified

235type Provider interface {
236 // Stream 流式对话
237 Stream(ctx context.Context, messages []types.Message, opts *StreamOptions) (<-chan StreamChunk, error)
238
239 // Complete 非流式对话(阻塞式,返回完整响应)
240 Complete(ctx context.Context, messages []types.Message, opts *StreamOptions) (*CompleteResponse, error)

Callers 6

StreamMethod · 0.65
StreamChatMethod · 0.65
streamingExampleFunction · 0.65
collectExampleFunction · 0.65
filterExampleFunction · 0.65
lastEventExampleFunction · 0.65

Implementers 12

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
MockProviderpkg/agent/model_fallback_test.go
MockProviderserver/test_helpers.go

Calls

no outgoing calls

Tested by

no test coverage detected