Method WaitDone

async/queue.go:85–87

WaitDone stops until all jobs on the queue have been processed.

()

// WaitDone stops until all jobs on the queue have been processed.
func (wq *WorkQueue) WaitDone() {
	wq.jobs.Wait()
}

// Stop stops the job queue and the workers.
func (wq *WorkQueue) Stop() {