cpp-software-patterns/RxObserver/SubjectPolicy.cpp 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
#include "RxObserver/SubjectPolicy.h"

namespace BaseLib { namespace Concurrent
{

SubjectPolicy::SubjectPolicy()
    : timeout_(Policy::Timeout::FromSeconds(30))
    , computation_(Policy::Computation::Concurrent())
    , invocation_(Policy::Invocation::Async())
    , maxNumSubscribers_(Policy::MaxLimit<int>::InclusiveLimitTo(std::numeric_limits<int>::max()))
    , maxNumPublishers_(Policy::MaxLimit<int>::InclusiveLimitTo(std::numeric_limits<int>::max()))
{ }

SubjectPolicy::~SubjectPolicy()
{ }

Policy::Timeout SubjectPolicy::Timeout() const
{
    return timeout_;
}

Policy::TimeBasedFilter SubjectPolicy::MinSeparation() const
{
    return filterInterval_;
}

Policy::Replay SubjectPolicy::Replay() const
{
    return replay_;
}

Policy::Ordering SubjectPolicy::Ordering() const
{
    return ordering_;
}

Policy::Invocation SubjectPolicy::Invocation() const
{
    return invocation_;
}

Policy::Computation SubjectPolicy::Computation() const
{
    return computation_;
}

int SubjectPolicy::MaxNumSubscribers() const
{
    return maxNumSubscribers_.Clone();
}

int SubjectPolicy::MaxNumPublishers() const
{
    return maxNumPublishers_.Clone();
}

FlowControllerPolicy SubjectPolicy::FlowPolicy() const
{
    return flowPolicy_;
}

}}