Function TestConsumer_Cancel_willNotBlock

consumer_test.go:54–69

(t *testing.T)

}

func TestConsumer_Cancel_willNotBlock(t *testing.T) {
	var ok bool
	c := newTestConsumer()

	go func() {
		c.Cancel()
		c.Cancel()
		c.Cancel()
		ok = true
	}()

	time.Sleep(1 * time.Microsecond) // let goroutine to work
	if !ok {
		t.Error("shold not block")
	}
}

func TestConsumer_Deliveries(t *testing.T) {
	c := newTestConsumer()