We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c3c10a5 commit 56600ecCopy full SHA for 56600ec
queue.go
@@ -54,9 +54,9 @@ var ErrMissingWorker = errors.New("missing worker module")
54
func NewQueue(opts ...Option) (*Queue, error) {
55
o := NewOptions(opts...)
56
q := &Queue{
57
- workerCount: o.workerCount,
58
routineGroup: newRoutineGroup(),
59
quit: make(chan struct{}),
+ workerCount: o.workerCount,
60
logger: o.logger,
61
timeout: o.timeout,
62
worker: o.worker,
0 commit comments