Method NotifyNewEvents

appservice/types/types.go:41–46

NotifyNewEvents wakes up all waiting goroutines, notifying that events remain in the event queue for this application service worker.

()

// NotifyNewEvents wakes up all waiting goroutines, notifying that events remain
// in the event queue for this application service worker.
func (a *ApplicationServiceWorkerState) NotifyNewEvents() {
	a.Cond.L.Lock()
	a.EventsReady = true
	a.Cond.Broadcast()
	a.Cond.L.Unlock()
}

// FinishEventProcessing marks all events of this worker as being sent to the
// application service.