WorkQueue.close
void close() @trustedClose the queue, preventing further pushes.
Pending consumers will be woken up and receive QueueStatus.CLOSED once the queue is drained.
void close() @trustedClose the queue, preventing further pushes.
Pending consumers will be woken up and receive QueueStatus.CLOSED once the queue is drained.