MCPcopy
hub / github.com/nats-io/nats.go / push

Method push

micro/service.go:512–514  ·  view source on GitHub ↗

dispatch is responsible for calling any async callbacks

(f func())

Source from the content-addressed store, hash-verified

510
511// dispatch is responsible for calling any async callbacks
512func (ac *asyncCallbacksHandler) push(f func()) {
513 ac.cbQueue <- f
514}
515
516func (ac *asyncCallbacksHandler) close() {
517 if ac.closed {

Callers 2

AddServiceFunction · 0.45
StopMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected