MCPcopy
hub / github.com/SurgeDM/Surge / StreamEvents

Method StreamEvents

internal/core/interface.go:46–46  ·  view source on GitHub ↗

StreamEvents returns a channel that receives real-time download events. For local mode, this is a direct channel. For remote mode, this is sourced from SSE.

(ctx context.Context)

Source from the content-addressed store, hash-verified

44 // For local mode, this is a direct channel.
45 // For remote mode, this is sourced from SSE.
46 StreamEvents(ctx context.Context) (<-chan interface{}, func(), error)
47
48 // Publish emits an event into the service's event stream.
49 Publish(msg interface{}) error

Implementers 7

mockServiceinternal/tui/delete_resilience_test.go
LocalDownloadServiceinternal/core/local_service.go
RemoteDownloadServiceinternal/core/remote_service.go
fakeRemoteDownloadServicecmd/connect_test.go
httpAPITestServicecmd/http_api_test.go
rateLimitWrappercmd/http_api_test.go
countingLifecycleServicecmd/root_lifecycle_test.go

Calls

no outgoing calls