FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
simple-binary-encoding/test/cpp/BasicOtfApiTest.cpp at master · bruce2008github/simple-binary-encoding · GitHub
bruce2008github
/
simple-binary-encoding
Public
forked from
aeron-io/simple-binary-encoding
Notifications
You must be signed in to change notification settings
Fork
0
Star
1
Code
Pull requests
0
Actions
Projects
Wiki
Security and quality
0
Insights
Additional navigation options
Code
Pull requests
Actions
Projects
Wiki
Security and quality
Insights
Expand file tree
Breadcrumbs
simple-binary-encoding
/
test
/
cpp
/
BasicOtfApiTest.cpp
Copy path
More file actions
More file actions
Latest commit
History
History
History
91 lines (79 loc) · 1.84 KB
Breadcrumbs
simple-binary-encoding
/
test
/
cpp
/
BasicOtfApiTest.cpp
Copy path
File metadata and controls
91 lines (79 loc) · 1.84 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
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
/*
* Copyright 2013 Real Logic Ltd.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#
include
<
deque
>
#
include
<
iostream
>
#
include
"
gtest/gtest.h
"
#
include
"
otf_api/Listener.h
"
using
namespace
sbe
::on_the_fly
;
using
::std::cout;
using
::std::endl;
TEST
(BasicOtfApi, shouldHandleListenerCreation)
{
Listener listener;
}
class
TestListener
:
public
Listener
{
private:
std::deque<Field> fieldQ_;
public:
TestListener
() : Listener() {};
virtual
int
process
(
void
)
{
while
(!fieldQ_.
empty
())
{
Field f = fieldQ_.
front
();
Listener::deliver
(f);
fieldQ_.
pop_front
();
}
return
0
;
};
TestListener &
add
(
const
Field &f)
{
fieldQ_.
push_back
(f);
return
*
this
;
};
};
class
OnNextCounter
:
public
OnNext
{
private:
int
count_;
public:
OnNextCounter
() : count_(
0
) {};
virtual
int
onNext
(
const
Field &)
{
count_++;
return
0
;
};
virtual
int
onNext
(
const
Group &)
{
return
0
;
};
int
count
(
void
)
{
return
count_;
};
};
/*
* Could have made this a fixture, but want to use it directly.
*/
TEST
(BasicOtfApi, shouldHandleOnNext)
{
Field f1, f2;
OnNextCounter counter;
TestListener listener;
listener.
add
(f1).
add
(f2).
subscribe
(&counter);
EXPECT_EQ
(counter.
count
(),
2
);
}
Back
|
FazBrowse Home
|
New Git URL