Versions in this module Expand all Collapse all v1 v1.12.0 Jul 26, 2016 Changes in this version + type Queue struct + func NewQueue(buffer int) *Queue + func (q *Queue) CallbackWatch(matcher events.Matcher) (eventq chan events.Event, cancel func()) + func (q *Queue) Publish(item events.Event) + func (q *Queue) Watch() (eventq chan events.Event, cancel func())
Go to main page