MCPcopy Create free account

hub / github.com/asaskevich/EventBus / functions

Functions60 in github.com/asaskevich/EventBus

⨍ Functions 60◇ Types & classes 16
↓ 18 callersFunctionNew
New returns new EventBus with empty handlers.
event_bus.go:52
↓ 14 callersMethodPublish
(topic string, args ...interface{})
event_bus.go:20
↓ 13 callersMethodSubscribe
(topic string, fn interface{})
event_bus.go:11
↓ 5 callersMethodHasCallback
(topic string)
event_bus.go:25
↓ 4 callersFunctionNewClient
NewClient - create a client object with the address and server path
client.go:32
↓ 4 callersFunctionNewServer
NewServer - create a new Server at the address and path
server.go:46
↓ 4 callersMethodSubscribeOnce
(topic string, fn interface{})
event_bus.go:13
↓ 4 callersMethodUnsubscribe
(topic string, handler interface{})
event_bus.go:15
↓ 4 callersMethodWaitAsync
()
event_bus.go:26
↓ 4 callersMethoddoSubscribe
doSubscribe handles the subscription logic and is utilized by the public Subscribe functions
event_bus.go:62
↓ 3 callersMethodRegister
Register - Registers a remote handler to this event bus for a remote subscribe - a given client address only needs to subscribe once event will be rep
server.go:132
↓ 2 callersMethodEventBus
EventBus - returns wrapped event bus
network_bus.go:36
↓ 2 callersFunctionNewNetworkBus
NewNetworkBus - returns a new network bus object at the server address and path
network_bus.go:24
↓ 2 callersMethodStart
Start - starts a service for remote clients to subscribe to events
server.go:92
↓ 2 callersMethodStart
Start - helper method to serve a network bus service
network_bus.go:47
↓ 2 callersMethodStart
Start - starts the client service to listen to remote events
client.go:80
↓ 2 callersMethodStop
Stop - signal for the service to stop serving
server.go:114
↓ 2 callersMethodStop
Stop - signal for the service to stop serving
network_bus.go:70
↓ 2 callersMethodStop
Stop - signal for the service to stop serving
client.go:100
↓ 2 callersMethodSubscribeAsync
(topic string, fn interface{}, transactional bool)
event_bus.go:12
↓ 2 callersMethoddoPublish
(handler *eventHandler, topic string, args ...interface{})
event_bus.go:158
↓ 2 callersMethoddoSubscribe
(topic string, fn interface{}, serverAddr, serverPath string, subscribeType SubscribeType)
client.go:46
↓ 2 callersMethodremoveHandler
(topic string, idx int)
event_bus.go:171
↓ 1 callersMethodEventBus
EventBus - returns wrapped event bus
server.go:57
↓ 1 callersMethodHasClientSubscribed
HasClientSubscribed - True if a client subscribed to this server with the same topic
server.go:80
↓ 1 callersMethodPushEvent
PushEvent - exported service to listening to remote events
client.go:116
↓ 1 callersMethodSubscribe
Subscribe subscribes to a topic in a remote event bus
client.go:70
↓ 1 callersMethodSubscribeOnceAsync
(topic string, fn interface{})
event_bus.go:14
↓ 1 callersMethoddoPublishAsync
(handler *eventHandler, topic string, args ...interface{})
event_bus.go:163
↓ 1 callersMethodfindHandlerIdx
(topic string, callback reflect.Value)
event_bus.go:186
↓ 1 callersMethodrpcCallback
(subscribeArg *SubscribeArg)
server.go:61
↓ 1 callersMethodsetUpPublish
(callback *eventHandler, args ...interface{})
event_bus.go:198
MethodEventBus
EventBus - returns the underlying event bus
client.go:42
MethodHandle
()
event_bus_test.go:78
MethodHasCallback
HasCallback returns true if exists any callback subscribed to the topic.
event_bus.go:108
MethodPublish
Publish executes callback defined for a topic. Any additional argument will be transferred to the callback.
event_bus.go:131
MethodSubscribe
Subscribe subscribes to a topic. Returns error if `fn` is not a function.
event_bus.go:74
MethodSubscribeAsync
SubscribeAsync subscribes to a topic with an asynchronous callback Transactional determines whether subsequent callbacks for a topic are run serially
event_bus.go:84
MethodSubscribeOnce
SubscribeOnce subscribes to a topic once. Handler will be removed after executing. Returns error if `fn` is not a function.
event_bus.go:92
MethodSubscribeOnce
SubscribeOnce subscribes once to a topic in a remote event bus
client.go:75
MethodSubscribeOnceAsync
SubscribeOnceAsync subscribes to a topic once with an asynchronous callback Handler will be removed after executing. Returns error if `fn` is not a fu
event_bus.go:101
FunctionTestHasCallback
(t *testing.T)
event_bus_test.go:16
FunctionTestNetworkBus
(t *testing.T)
network_bus_test.go:87
FunctionTestNew
(t *testing.T)
event_bus_test.go:8
FunctionTestNewClient
(t *testing.T)
network_bus_test.go:17
FunctionTestNewServer
(t *testing.T)
network_bus_test.go:7
FunctionTestPublish
(t *testing.T)
event_bus_test.go:102
FunctionTestPushEvent
(t *testing.T)
network_bus_test.go:44
FunctionTestRegister
(t *testing.T)
network_bus_test.go:27
FunctionTestServerPublish
(t *testing.T)
network_bus_test.go:66
FunctionTestSubcribeOnceAsync
(t *testing.T)
event_bus_test.go:116
FunctionTestSubscribe
(t *testing.T)
event_bus_test.go:27
FunctionTestSubscribeAsync
(t *testing.T)
event_bus_test.go:162
FunctionTestSubscribeAsyncTransactional
(t *testing.T)
event_bus_test.go:138
FunctionTestSubscribeOnce
(t *testing.T)
event_bus_test.go:37
FunctionTestSubscribeOnceAndManySubscribe
(t *testing.T)
event_bus_test.go:47
FunctionTestUnsubscribe
(t *testing.T)
event_bus_test.go:62
FunctionTestUnsubscribeMethod
(t *testing.T)
event_bus_test.go:82
MethodUnsubscribe
Unsubscribe removes callback defined for a topic. Returns error if there are no callbacks subscribed to the topic.
event_bus.go:120
MethodWaitAsync
WaitAsync waits for all async callbacks to complete
event_bus.go:213