//          Copyright Sebastian Jeckel 2014.
// Distributed under the Boost Software License, Version 1.0.
//    (See accompanying file LICENSE_1_0.txt or copy at
//          http://www.boost.org/LICENSE_1_0.txt)

#ifndef REACT_DETAIL_EVENTBASE_H_INCLUDED
#define REACT_DETAIL_EVENTBASE_H_INCLUDED

#pragma once

#include "react/detail/Defs.h"

#include <utility>

#include "react/detail/ReactiveBase.h"
#include "react/detail/ReactiveInput.h"
#include "react/detail/graph/EventNodes.h"

/***************************************/ REACT_IMPL_BEGIN /**************************************/

///////////////////////////////////////////////////////////////////////////////////////////////////
/// EventStreamBase
///////////////////////////////////////////////////////////////////////////////////////////////////
template
<
    typename D,
    typename E
>
class EventStreamBase : public CopyableReactive<EventStreamNode<D,E>>
{
public:
    EventStreamBase() = default;
    EventStreamBase(const EventStreamBase&) = default;

    template <typename T>
    EventStreamBase(T&& t) :
        EventStreamBase::CopyableReactive( std::forward<T>(t) )
    {}

protected:
    template <typename T>
    void emit(T&& e) const
    {
        DomainSpecificInputManager<D>::Instance().AddInput(
            *reinterpret_cast<EventSourceNode<D,E>*>(this->ptr_.get()),
            std::forward<T>(e));
    }
};

/****************************************/ REACT_IMPL_END /***************************************/

#endif // REACT_DETAIL_EVENTBASE_H_INCLUDED