We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5802bb8 commit f87e1f4Copy full SHA for f87e1f4
1 file changed
diskqueue.go
@@ -93,6 +93,7 @@ func (queue *Diskqueue) Close() {
93
}
94
95
queue.close = true
96
+ queue.ticker.Stop()
97
queue.cancel()
98
queue.wg.Wait()
99
Writer.close()
0 commit comments