Method Dispatch

message.go:49–63

Dispatch sends a message to all subscribed handlers of the message's type To prevent any data races, be aware that these listeners occur as callbacks and can be executed at any time. If variables are altered in the handler, utilize channels, locks, semaphores, or any other method necessary to ensure

(message Message)

// semaphores, or any other method necessary to ensure the memory is not altered by multiple
// functions simultaneously.
func (mm *MessageManager) Dispatch(message Message) {
	mm.RLock()
	mm.clearRemovedHandlers()
	handlers := make([]MessageHandler, len(mm.listeners[message.Type()]))
	pairs := mm.listeners[message.Type()]
	for i := range pairs {
		handlers[i] = pairs[i].MessageHandler
	}
	mm.RUnlock()

	for _, handler := range handlers {
		handler(message)
	}

}

// Listen subscribes to the specified message type and calls the specified handler when fired
func (mm *MessageManager) Listen(messageType string, handler MessageHandler) MessageHandlerId {