diff --git a/libs/pushstreams/api/celix/impl/BufferedPushStream.h b/libs/pushstreams/api/celix/impl/BufferedPushStream.h index 5172f42ed..6a2d1e6fd 100644 --- a/libs/pushstreams/api/celix/impl/BufferedPushStream.h +++ b/libs/pushstreams/api/celix/impl/BufferedPushStream.h @@ -98,10 +98,10 @@ void celix::BufferedPushStream::startWorker() { std::weak_ptr>>> weak{queue}; auto lk = weak.lock(); if (lk) { - std::unique_ptr> event = std::move(popQueue()); + std::unique_ptr> event = popQueue(); while (event != nullptr) { this->nextEvent.accept(*event); - event = std::move(popQueue()); + event = popQueue(); } cv.notify_all(); }