|
@@ -47,7 +47,7 @@ public:
|
|
|
std::weak_ptr<BaseNode> weak_self = shared_from_this();
|
|
|
buffer->set_push_callback([weak_self]() {
|
|
|
if (auto self = weak_self.lock()) {
|
|
|
- self->cond_var_.notify_one();
|
|
|
+ self->cond_var_->notify_one();
|
|
|
}
|
|
|
});
|
|
|
output_buffers_[name] = buffer;
|