Commit 914428fa authored by Dominik Charousset's avatar Dominik Charousset

Add missing override

parent 3dd9372c
...@@ -86,6 +86,11 @@ public: ...@@ -86,6 +86,11 @@ public:
discard(); discard();
} }
bool disposed() const noexcept override {
std::unique_lock guard{mtx_};
return mgr_ == nullptr;
}
void on_complete() { void on_complete() {
std::unique_lock guard{mtx_}; std::unique_lock guard{mtx_};
if (sink_) { if (sink_) {
...@@ -206,7 +211,7 @@ private: ...@@ -206,7 +211,7 @@ private:
} }
} }
std::recursive_mutex mtx_; mutable std::recursive_mutex mtx_;
/// Allocated to max_in_flight_ * 2, but at most holds max_in_flight_ elements /// Allocated to max_in_flight_ * 2, but at most holds max_in_flight_ elements
/// at any point in time. We dynamically shift elements into the first half of /// at any point in time. We dynamically shift elements into the first half of
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment