MCPcopy
hub / github.com/livebud/bud / Subscription

Interface Subscription

internal/pubsub/pubsub.go:20–23  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

18}
19
20type Subscription interface {
21 Wait() <-chan []byte
22 Close()
23}
24
25func New() *Memory {
26 return &Memory{

Callers 11

ServeFunction · 0.65
TestServeFunction · 0.65
TestEventsFunction · 0.65
WaitMethod · 0.65
TestServerCancelFunction · 0.65
TestServerListenCancelFunction · 0.65
TestErrGroupFunction · 0.65
TestServerWaitNoServeFunction · 0.65
TestPubSubFunction · 0.65
TestCloseTwiceFunction · 0.65
TestSubTwiceFunction · 0.65

Implementers 5

Serverpackage/budhttp/budsvr/server.go
Processinternal/shell/command.go
Clientinternal/testcli/testcli.go
subscriberinternal/pubsub/pubsub.go
discardableinternal/pubsub/discard.go

Calls

no outgoing calls

Tested by

no test coverage detected