| 196 | }; |
| 197 | |
| 198 | std::size_t cancelAndPrint(ConcurrentQueue &queue, const QueueControlMessagePrinter &printer) |
| 199 | { |
| 200 | const auto canceledCount = queue.cancelPending(); |
| 201 | printer.printCanceledMessage(canceledCount); |
| 202 | return canceledCount; |
| 203 | } |
| 204 | |
| 205 | void waitAndPrint(const ConcurrentQueue &queue, const QueueControlMessagePrinter &printer) |
| 206 | { |
no test coverage detected