|
|
@ -61,7 +61,7 @@ public:
|
|
|
|
const std::function<void()>& worker_teardown_cb = nullptr);
|
|
|
|
const std::function<void()>& worker_teardown_cb = nullptr);
|
|
|
|
|
|
|
|
|
|
|
|
//Wait for the queue to be empty, and flush synchronously
|
|
|
|
//Wait for the queue to be empty, and flush synchronously
|
|
|
|
//Warning: this can potentialy last forever as we wait it to complete
|
|
|
|
//Warning: this can potentially last forever as we wait it to complete
|
|
|
|
void flush() override;
|
|
|
|
void flush() override;
|
|
|
|
|
|
|
|
|
|
|
|
// Error handler
|
|
|
|
// Error handler
|
|
|
|