dispatch

Aug 10, 2021

Changes in this version

type MessageQueue

+ func (q *MessageQueue) WaitForMessage(what int)

May 18, 2021

Changes in this version

+ const MessageEmpty

+ const MessageExit

+ const MessageWorkExec

+ type CallbackHandler func(message *Message)

+ type Looper interface

+ GetMessageDispatcher func() MessageDispatcher

+ Loop func()

+ type LooperImpl struct

+ func NewLooperImpl(messageQueueBuffer uint) *LooperImpl

+ func NewLooperImplCompat(messageQueueBuffer int) *LooperImpl

+ func (l *LooperImpl) Execute(item WorkItem)

+ func (l *LooperImpl) GetMessageDispatcher() MessageDispatcher

+ func (l *LooperImpl) GetWorkDispatcher() WorkDispatcher

+ func (l *LooperImpl) Loop()

+ func (l *LooperImpl) RemoveMessageHandler(what int)

+ func (l *LooperImpl) SendMessage(message *Message)

+ func (l *LooperImpl) SetMessageHandler(what int, handler MessageHandlerFunc)

+ type Message struct

+ AnyData interface{}

+ Id int

+ ReplyTo *Message

+ StrData string

+ What int

+ func NewMessage(what int) *Message

+ func NewMessageWithAnyData(what int, data interface{}) *Message

+ func NewMessageWithStringData(what int, data string) *Message

+ type MessageDispatcher interface

+ SendMessage func(message *Message)

+ type MessageHandler interface

+ OnMessage func(msg *Message)

+ type MessageHandlerFunc func(message *Message)

+ type MessageQueue struct

+ func NewMessageQueue(bufferSize uint) *MessageQueue

+ func (q *MessageQueue) Close()

+ func (q *MessageQueue) Dequeue() *Message

+ func (q *MessageQueue) DequeueBlocking() *Message

+ func (q *MessageQueue) Enqueue(message *Message)

+ func (q *MessageQueue) GetSize() uint

+ func (q *MessageQueue) IsEmpty() bool

+ func (q *MessageQueue) LockMainChannel()

+ func (q *MessageQueue) UnlockMainChannel()

+ type WorkDispatcher interface

+ Execute func(item WorkItem)

+ type WorkItem interface

+ Execute func()

+ type WorkItemFunc struct

+ func NewWorkItemFunc(work func()) *WorkItemFunc

+ func (w *WorkItemFunc) Execute()