MCPcopy Create free account
hub / github.com/akash-network/node / Subscribe

Method Subscribe

pubsub/bus.go:26–26  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

24type Bus interface {
25 Publisher
26 Subscribe() (Subscriber, error)
27 Close()
28 Done() <-chan struct{}
29}

Callers 5

TestBusFunction · 0.95
TestCloneFunction · 0.95
stateMachineMethod · 0.65
runMethod · 0.65
stateMachineMethod · 0.65

Implementers 1

buspubsub/bus.go

Calls

no outgoing calls

Tested by 5

TestBusFunction · 0.76
TestCloneFunction · 0.76
stateMachineMethod · 0.52
runMethod · 0.52
stateMachineMethod · 0.52