Wait until all job get done
()
| 98 | |
| 99 | //Wait until all job get done |
| 100 | func (queue *Queue) Wait() { |
| 101 | queue.waitGroup.Wait() |
| 102 | } |
| 103 | |
| 104 | //Stop stops all worker after all job get done |
| 105 | func (queue *Queue) Stop() { |
no outgoing calls
no test coverage detected