testqueue

type Queue ¶

type Queue struct {
	// contains filtered or unexported fields
}

The Queue struct implements a multi-writer/multi-reader concurrent queue where the dequeue operation (the Get() method) takes a predicate that allows it to skip past queue entries until it finds one that satisfies the specified predicate.

func NewQueue(t *testing.T, timeout time.Duration) *Queue

func (q *Queue) Add(t *testing.T, obj interface{})

func (q *Queue) AssertEmpty(t *testing.T, timeout time.Duration, msg string)

func (q *Queue) Get(t *testing.T, predicate func(interface{}) bool) (interface{}, error)