#pragma once
#include <condition_variable>
template <class T>
class Condition
{
public:

        std::mutex m_mutex;
        std::condition_variable   m_condition;
        ~Condition() {
                m_condition.notify_all();
        }
        void notify(std::unique_ptr<T> data) noexcept
        {
                {
                        std::lock_guard<std::mutex> eventLock(m_mutex);
                        any.swap(data);
                }
                // wake up one waiter
                m_condition.notify_one();
        };


        std::unique_ptr<T> wait(unsigned timeout=0)
        {
                std::unique_lock<std::mutex> ul(m_mutex);
                if (!timeout) {
                        m_condition.wait(ul,[&]() {
                                        if (!any)
                                                return false;
                                        return true;
                        });
                }
                else{
                        if(!any){
                                std::cv_status status = m_condition.wait_for(ul, std::chrono::milliseconds(timeout));
                                if (status == std::cv_status::timeout)
                                {
                                        return {};
                                }
                        }
                }
                return std::unique_ptr<T>(any.release());

        }
private:
        std::unique_ptr<T> any;
};