@@ -38,7 +38,7 @@ class Counter : public Reactor {
38
38
Output<int > count{" count" , this }; // NOLINT
39
39
40
40
void assemble () override {
41
- std::cout << " assemble Counter" << std::endl << std::flush ;
41
+ std::cout << " assemble Counter\n " ;
42
42
r_trigger.declare_trigger (&trigger);
43
43
r_trigger.declare_antidependency (&count);
44
44
}
@@ -60,11 +60,11 @@ class Printer : public Reactor {
60
60
: Reactor(name, env) {}
61
61
62
62
void assemble () override {
63
- std::cout << " assemble Printer" << std::endl << std::flush ;
63
+ std::cout << " assemble Printer\n " ;
64
64
r_value.declare_trigger (&value);
65
65
}
66
66
67
- void on_value () { std::cout << this ->name () << " : " << *value.get () << std::endl ; }
67
+ void on_value () { std::cout << this ->name () << " : " << *value.get () << ' \n ' ; }
68
68
};
69
69
70
70
class Adder : public Reactor {
@@ -88,7 +88,7 @@ class Adder : public Reactor {
88
88
void add () {
89
89
if (i1.is_present () && i2.is_present ()) {
90
90
sum.set (*i1.get () + *i2.get ());
91
- std::cout << " setting sum" << std::endl ;
91
+ std::cout << " setting sum\n " ;
92
92
}
93
93
}
94
94
};
@@ -120,10 +120,10 @@ auto main() -> int {
120
120
env.draw_connection (add.sum , p_add.forward , ConnectionProperties{ConnectionType::Delayed, 10s, nullptr });
121
121
env.draw_connection (p_add.forward , p_add.value , ConnectionProperties{ConnectionType::Delayed, 5s, nullptr });
122
122
123
- std::cout << " assemble" << std::endl << std::flush ;
123
+ std::cout << " assemble\n " ;
124
124
env.assemble ();
125
125
126
- std::cout << " optimize" << std::endl << std::flush ;
126
+ std::cout << " optimize\n " ;
127
127
auto thread = env.startup ();
128
128
thread.join ();
129
129
0 commit comments