diff --git a/src/asyncrpcqueue.cpp b/src/asyncrpcqueue.cpp index a63619f0b..385709a61 100644 --- a/src/asyncrpcqueue.cpp +++ b/src/asyncrpcqueue.cpp @@ -34,6 +34,9 @@ void AsyncRPCQueue::run(size_t workerId) { // Exit if the queue is closing. if (isClosed()) { + while (!operation_id_queue_.empty()) { + operation_id_queue_.pop(); + } break; }