Done returns a channel that is closed when the Queue is closed (either via Close or Cancel). Multiple calls always return the same channel.
()
| 159 | // Done returns a channel that is closed when the Queue is closed (either |
| 160 | // via Close or Cancel). Multiple calls always return the same channel. |
| 161 | func (q *Queue) Done() <-chan struct{} { |
| 162 | return q.done |
| 163 | } |
| 164 | |
| 165 | // Cancel closes the Queue and drains the pending commands without processing |
| 166 | // them, allowing for a fast "stop immediately"-ish operation. |
no outgoing calls