Versions in this module Expand all Collapse all v0 v0.2.1 Dec 14, 2016 Changes in this version + type ProcessType interface + Process func(func(item interface{}) error) + type ProcessingQueue struct + func (p *ProcessingQueue) Process(f func(item interface{}) error) error + type Queue struct + func NewQueue() *Queue + func (n *Queue) Add(item interface{}) + func (n *Queue) Close() + func (n *Queue) Done(item interface{}) + func (n *Queue) Get() (item interface{}, quit bool) + func (n *Queue) Len() int + func (n *Queue) Remove(item interface{}) + type QueueAddType interface + Add func(interface{}) + type QueueType interface + Close func() + Done func(interface{}) + Get func() (interface{}, bool) + Len func() int + Remove func(interface{})
Go to main page