diff options
| author | Anatoly Shirokov <anatoly.shirokov@gmail.com> | 2017-03-30 18:42:44 +0300 |
|---|---|---|
| committer | Grigoriy Chudnov <g.chudnov@gmail.com> | 2017-04-09 12:08:57 +0300 |
| commit | e024142dc3b23c229e6b375fdf7c5516df7c8437 (patch) | |
| tree | d42339b149c80e4c9942fcee15cfae6ba88c589d /Rx | |
| parent | 00fdd5b890664222e1b8dca317907950eea1f8f6 (diff) | |
| download | RxCpp-e024142dc3b23c229e6b375fdf7c5516df7c8437.tar.gz | |
fixed https://github.com/Reactive-Extensions/RxCpp/issues/366
Diffstat (limited to 'Rx')
| -rw-r--r-- | Rx/v2/src/rxcpp/schedulers/rx-test.hpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/Rx/v2/src/rxcpp/schedulers/rx-test.hpp b/Rx/v2/src/rxcpp/schedulers/rx-test.hpp index 86d426a..3f73e52 100644 --- a/Rx/v2/src/rxcpp/schedulers/rx-test.hpp +++ b/Rx/v2/src/rxcpp/schedulers/rx-test.hpp @@ -340,8 +340,9 @@ public: template<class T> rxt::testable_observable<T> test_type::make_hot_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::detail::notification_base<T>>>> messages) const { - return rxt::testable_observable<T>( - std::make_shared<hot_observable<T>>(state, create_worker(composite_subscription()), std::move(messages))); + auto worker = create_worker(composite_subscription()); + auto shared = std::make_shared<hot_observable<T>>(state, worker, std::move(messages)); + return rxt::testable_observable<T>(shared); } template<class F> |