MCPcopy Create free account
hub / github.com/astercloud/aster / dispatcher

Method dispatcher

pkg/actor/system.go:419–430  ·  view source on GitHub ↗

dispatcher 全局消息分发器

()

Source from the content-addressed store, hash-verified

417
418// dispatcher 全局消息分发器
419func (s *System) dispatcher() {
420 defer s.wg.Done()
421
422 for {
423 select {
424 case <-s.ctx.Done():
425 return
426 case env := <-s.mailbox:
427 s.dispatchMessage(env)
428 }
429 }
430}
431
432// dispatchMessage 分发单条消息
433func (s *System) dispatchMessage(env envelope) {

Callers 1

NewSystemWithConfigFunction · 0.95

Calls 1

dispatchMessageMethod · 0.95

Tested by

no test coverage detected