diff options
Diffstat (limited to 'Rx')
| -rw-r--r-- | Rx/v2/src/rxcpp/subjects/rx-subject.hpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/Rx/v2/src/rxcpp/subjects/rx-subject.hpp b/Rx/v2/src/rxcpp/subjects/rx-subject.hpp index 4ead228..f94f8f9 100644 --- a/Rx/v2/src/rxcpp/subjects/rx-subject.hpp +++ b/Rx/v2/src/rxcpp/subjects/rx-subject.hpp @@ -149,7 +149,7 @@ public: } } template<class V> - void on_next(V&& v) const { + void on_next(V v) const { if (b->current_generation != b->state->generation) { std::unique_lock<std::mutex> guard(b->state->lock); b->current_generation = b->state->generation; @@ -160,7 +160,7 @@ public: } for (auto& o : b->current_completer->observers) { if (o.is_subscribed()) { - o.on_next(std::forward<V>(v)); + o.on_next(v); } } } |