File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -91,11 +91,11 @@ class behavior
91
91
92
92
observable<T> get_observable () const {
93
93
auto keepAlive = s;
94
- return make_observable_dynamic<T>([keepAlive, this ](subscriber<T> o){
94
+ return make_observable_dynamic<T>([keepAlive](subscriber<T> o){
95
95
if (keepAlive.get_subscription ().is_subscribed ()) {
96
- o.on_next (get_value ());
96
+ o.on_next (keepAlive. get_value ());
97
97
}
98
- keepAlive.add (s .get_subscriber (), std::move (o));
98
+ keepAlive.add (keepAlive .get_subscriber (), std::move (o));
99
99
});
100
100
}
101
101
};
Original file line number Diff line number Diff line change @@ -169,8 +169,8 @@ class replay
169
169
170
170
observable<T> get_observable () const {
171
171
auto keepAlive = s;
172
- auto observable = make_observable_dynamic<T>([keepAlive, this ](subscriber<T> o){
173
- for (auto && value: get_values ()) {
172
+ auto observable = make_observable_dynamic<T>([keepAlive](subscriber<T> o){
173
+ for (auto && value: keepAlive. get_values ()) {
174
174
o.on_next (value);
175
175
}
176
176
keepAlive.add (keepAlive.get_subscriber (), std::move (o));
You can’t perform that action at this time.
0 commit comments