cpp-software-patterns/RxTransport/ChannelFeedbackEvent.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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
#pragma once

#include "CommonDefines.h"

namespace BaseLib { namespace Concurrent {

template <typename T, typename U>
class ChannelFeedbackEvent
{
public:
    virtual ~ChannelFeedbackEvent()
    { }

    virtual void OnChannelFeedback(T t, U u) = 0;
};

template <typename T, typename U, typename V>
class MessageFeedbackEvent
{
public:
    virtual ~MessageFeedbackEvent()
    { }

    virtual void OnMessageFeedback(T t, U u, V v) = 0;
};


template <typename T, typename U, typename V>
class MessageFeedbackObserver
    : public MessageFeedbackEvent<T, U, V>
      , public Concurrent::ObserverSlot<MessageFeedbackObserver<T, U, V>>
{
};

template <typename T, typename U>
class ChannelFeedbackObserver
    : public ChannelFeedbackEvent<T, U>
      , public Concurrent::ObserverSlot<ChannelFeedbackObserver<T, U>>
{
};


template <typename T, typename U>
class ChannelFeedbackSubject
    : public ChannelFeedbackEvent<T, U>
      , public Concurrent::Observable<ChannelFeedbackObserver<T, U>>
{
    typedef ChannelFeedbackObserver<T, U>      TheObserver;
    typedef Concurrent::Signaller2<void, T, U> TheSignaller;
    typedef std::shared_ptr<TheSignaller>      TheSignallerPtr;

public:
    ChannelFeedbackSubject()
        : signaller_(new TheSignaller())
    { }

    virtual ~ChannelFeedbackSubject()
    { }

    virtual void OnChannelFeedback(T t, U u)
    {
        signaller_->Signal(t, u);
    }

    virtual std::shared_ptr<SlotHolder> Connect(TheObserver* observer)
    {
        auto slot = signaller_->template Connect<TheObserver>(observer, &ChannelFeedbackEvent<T, U>::OnChannelFeedback);
        observer->AddSlot(observer, slot);
        return slot;
    }

    virtual bool Disconnect(TheObserver* observer)
    {
        return signaller_->template Disconnect<TheObserver>(observer);
    }

    virtual void DisconnectAll()
    {
        signaller_->DisconnectAll();
    }

private:
    TheSignallerPtr signaller_;
};

template <typename T, typename U, typename V>
class MessageFeedbackSubject
    : public MessageFeedbackEvent<T, U, V>
      , public Concurrent::Observable<MessageFeedbackObserver<T, U, V>>
{
    typedef MessageFeedbackObserver<T, U, V>      TheObserver;
    typedef Concurrent::Signaller3<void, T, U, V> TheSignaller;
    typedef std::shared_ptr<TheSignaller>         TheSignallerPtr;

public:
    MessageFeedbackSubject()
        : signaller_(new TheSignaller())
    { }

    virtual ~MessageFeedbackSubject()
    { }

    virtual void OnMessageFeedback(T t, U u, V v)
    {
        signaller_->Signal(t, u, v);
    }

    virtual std::shared_ptr<SlotHolder> Connect(TheObserver* observer)
    {
        auto slot = signaller_->template Connect<TheObserver>(observer, &MessageFeedbackEvent<T, U, V>::OnMessageFeedback);
        observer->AddSlot(observer, slot);
        return slot;
    }

    virtual bool Disconnect(TheObserver* observer)
    {
        return signaller_->template Disconnect<TheObserver>(observer);
    }

    virtual void DisconnectAll()
    {
        signaller_->DisconnectAll();
    }

private:
    TheSignallerPtr signaller_;
};

}}