Function TestQueue_IsStopped

engine/queue/queue_test.go:51–59

(t *testing.T)

}

func TestQueue_IsStopped(t *testing.T) {
	var q = New(zaptest.NewLogger(t).Sugar(), nil, nil, Options{
		Rate:      500 * time.Millisecond,
		BatchSize: 1,
	})
	if b := q.IsStopped(); b != q.stopped {
		t.Errorf("IsStopped = '%v', got '%v'", b, q.stopped)
	}
}