cpp.react/include/react/Reactor.h at master · jchjava/cpp.react · GitHub

History

76 lines (57 loc) · 1.72 KB

Raw

// 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_REACTOR_H_INCLUDED

#define REACT_REACTOR_H_INCLUDED

#pragma once

#include "react/detail/Defs.h"

#include <functional>

#include <memory>

#include <utility>

#include "react/common/Util.h"

#include "react/Event.h"

#include "react/detail/ReactiveBase.h"

#include "react/detail/graph/ReactorNodes.h"

/*****************************************/ REACT_BEGIN /*****************************************/

template <typename D>

class Reactor

{

public:

class Context;

using NodeT = REACT_IMPL::ReactorNode<D,Context>;

class Context

{

public:

Context(NodeT& node) :

node_( node )

{}

template <typename E>

E& Await(const Events<D,E>& evn)

{

return node_.Await(GetNodePtr(evn));

}

template <typename E, typename F>

void RepeatUntil(const Events<D,E>& evn, F&& func)

{

node_.RepeatUntil(GetNodePtr(evn), std::forward<F>(func));

}

template <typename S>

const S& Get(const Signal<D,S>& sig)

{

return node_.Get(GetNodePtr(sig));

}

private:

NodeT& node_;

};

template <typename F>

explicit Reactor(F&& func) :

nodePtr_( new REACT_IMPL::ReactorNode<D, Context>(std::forward<F>(func)) )

{

nodePtr_->StartLoop();

}

private:

std::unique_ptr<NodeT> nodePtr_;

};

/******************************************/ REACT_END /******************************************/

#endif // REACT_REACTOR_H_INCLUDED

cpp.react/include/react/Reactor.h at master · jchjava/cpp.react · GitHub

Expand file tree

Breadcrumbs

Reactor.h

Latest commit

History

Breadcrumbs

Reactor.h

File metadata and controls