cpp-software-patterns/RxStreamer/RxActionChain.h at master · intact-software-systems/cpp-software-patterns · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
#pragma once

#include"RxStreamer/IncludeExtLibs.h"
#include"RxStreamer/DataAccessController.h"
#include"RxStreamer/RxDataAccessController.h"
#include"RxStreamer/Export.h"

namespace Reactor
{

class DLL_STATE RxChain
{
public:
    virtual ~RxChain() {}

    virtual bool Subscribe() = 0;
    virtual bool IsInitialized() = 0;

    virtual DataAccessController::Ptr Controller() const = 0;
};

class DLL_STATE RxChainNoOp
        : public RxChain
{
public:
    virtual ~RxChainNoOp() {}

    virtual bool Subscribe() { return false; }
    virtual bool IsInitialized() { return false; }
    virtual DataAccessController::Ptr Controller() const { return DataAccessController::Ptr();  }
};

class DLL_STATE RxActionChain
        : public RxChain
{
public:
    RxActionChain(Templates::ActionContextPtr rxContext, RxData::CacheDescription masterCacheId, DataAccessControllerPolicy policy);
    virtual ~RxActionChain();

    CLASS_TRAITS(RxActionChain)

    // --------------------------------------------------
    // Factory functions
    // --------------------------------------------------

    static RxActionChain Empty();
    static RxActionChain Create(Templates::ActionContextPtr rxContext, RxData::CacheDescription masterCacheId);
    static RxActionChain Create(Templates::ActionContextPtr actionContext, RxData::CacheDescription cacheId, DataAccessControllerPolicy policy);

    // --------------------------------------------------
    // Interface RxChain
    // --------------------------------------------------

    virtual DataAccessController::Ptr Controller() const;

    virtual bool Subscribe();
    virtual bool IsInitialized();

    // --------------------------------------------------
    // Create and add groups
    // --------------------------------------------------

    RxDataAccessGroup Sequential();
    RxDataAccessGroup Parallel();

private:
    RxDataAccessController dataAccessController_;
};

}