diff options
| author | Grigoriy Chudnov <g.chudnov@gmail.com> | 2017-01-21 01:31:18 +0300 |
|---|---|---|
| committer | Kirk Shoop <kirk.shoop@microsoft.com> | 2017-01-21 09:14:18 -0800 |
| commit | 691498ee639980bff0218681cbf5d1ef2882ee06 (patch) | |
| tree | e88751f51bca63e73bc5bb0606ba6a7d3fb27564 /Rx/v2/src/rxcpp/rx-observable.hpp | |
| parent | 1a5d65be7548069c4df12750f5d8f78bb852c6c2 (diff) | |
| download | RxCpp-691498ee639980bff0218681cbf5d1ef2882ee06.tar.gz | |
decouple start_with from observable
Diffstat (limited to 'Rx/v2/src/rxcpp/rx-observable.hpp')
| -rw-r--r-- | Rx/v2/src/rxcpp/rx-observable.hpp | 28 |
1 files changed, 6 insertions, 22 deletions
diff --git a/Rx/v2/src/rxcpp/rx-observable.hpp b/Rx/v2/src/rxcpp/rx-observable.hpp index 9afceae..2863d43 100644 --- a/Rx/v2/src/rxcpp/rx-observable.hpp +++ b/Rx/v2/src/rxcpp/rx-observable.hpp @@ -1763,31 +1763,15 @@ public: return observable_member(retry_tag{}, *this, std::forward<AN>(an)...); } - /*! Start with the supplied values, then concatenate this observable. - - \tparam Value0 ... - \tparam ValueN the type of sending values - - \param v0 ... - \param vn values to send - - \return Observable that emits the specified items and then emits the items emitted by the source observable. - - \sample - \snippet start_with.cpp short start_with sample - \snippet output.txt short start_with sample - - Another form of this operator, rxcpp::observable<void, void>::start_with, gets the source observable as a parameter: - \snippet start_with.cpp full start_with sample - \snippet output.txt full start_with sample - */ - template<class Value0, class... ValueN> - auto start_with(Value0 v0, ValueN... vn) const + /*! @copydoc rx-start_with.hpp + */ + template<class... AN> + auto start_with(AN... an) const /// \cond SHOW_SERVICE_MEMBERS - -> decltype(rxo::start_with(std::move(v0), std::move(vn)...)(*(this_type*)nullptr)) + -> decltype(observable_member(start_with_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) /// \endcond { - return rxo::start_with(std::move(v0), std::move(vn)...)(*this); + return observable_member(start_with_tag{}, *this, std::forward<AN>(an)...); } /*! @copydoc rx-pairwise.hpp |