37     : public rxs::source_base<T>
52     void construct(SO&& source, rxs::tag_source&&) {  in construct()
78 …typename std::conditional<rxs::is_source<SOF>::value || rxo::is_operator<SOF>::value, rxs::tag_sou…  in dynamic_observable()
536 …static_assert(rxo::is_operator<source_operator_type>::value || rxs::is_source<source_operator_type…
644             decltype(rxs::from<ResultType>())>::type {  in lift_if()
645         return       rxs::from<ResultType>();  in lift_if()
1569         -> decltype(rxs::create<T>(std::move(os))) {  in create()
1570         return      rxs::create<T>(std::move(os));  in create()
1577         -> decltype(rxs::range<T>(first, last, step, identity_current_thread())) {  in range()
1578         return      rxs::range<T>(first, last, step, identity_current_thread());  in range()
1584         -> decltype(rxs::range<T>(first, last, step, std::move(cn))) {  in range()
1585         return      rxs::range<T>(first, last, step, std::move(cn));  in range()
1591         -> decltype(rxs::range<T>(first, last, std::move(cn))) {  in range()
1592         return      rxs::range<T>(first, last, std::move(cn));  in range()
1598         -> decltype(rxs::range<T>(first, std::move(cn))) {  in range()
1599         return      rxs::range<T>(first, std::move(cn));  in range()
1606         -> decltype(rxs::never<T>()) {  in never()
1607         return      rxs::never<T>();  in never()
1614         -> decltype(rxs::defer(std::move(of))) {  in defer()
1615         return      rxs::defer(std::move(of));  in defer()
1622         -> decltype(rxs::interval(period)) {  in interval()
1623         return      rxs::interval(period);  in interval()
1630         -> decltype(rxs::interval(period, std::move(cn))) {  in interval()
1631         return      rxs::interval(period, std::move(cn));  in interval()
1637         -> decltype(rxs::interval(initial, period)) {  in interval()
1638         return      rxs::interval(initial, period);  in interval()
1645         -> decltype(rxs::interval(initial, period, std::move(cn))) {  in interval()
1646         return      rxs::interval(initial, period, std::move(cn));  in interval()
1653         -> decltype(rxs::timer(at)) {  in timer()
1654         return      rxs::timer(at);  in timer()
1661         -> decltype(rxs::timer(after)) {  in timer()
1662         return      rxs::timer(after);  in timer()
1669         -> decltype(rxs::timer(when, std::move(cn))) {  in timer()
1670         return      rxs::timer(when, std::move(cn));  in timer()
1676         -> decltype(rxs::timer(when, std::move(cn))) {  in timer()
1677         return      rxs::timer(when, std::move(cn));  in timer()
1684         -> decltype(rxs::iterate(std::move(c), identity_current_thread())) {  in iterate()
1685         return      rxs::iterate(std::move(c), identity_current_thread());  in iterate()
1691         -> decltype(rxs::iterate(std::move(c), std::move(cn))) {  in iterate()
1692         return      rxs::iterate(std::move(c), std::move(cn));  in iterate()
1699         -> decltype(    rxs::from<T>()) {  in from()
1700         return          rxs::from<T>();  in from()
1707             decltype(   rxs::from<T>(std::move(cn)))>::type {  in from()
1708         return          rxs::from<T>(std::move(cn));  in from()
1715             decltype(   rxs::from(v0, vn...))>::type {  in from()
1716         return          rxs::from(v0, vn...);  in from()
1723             decltype(   rxs::from(std::move(cn), v0, vn...))>::type {  in from()
1724         return          rxs::from(std::move(cn), v0, vn...);  in from()
1731         -> decltype(rxs::just(std::move(v))) {  in just()
1732         return      rxs::just(std::move(v));  in just()
1738         -> decltype(rxs::just(std::move(v), std::move(cn))) {  in just()
1739         return      rxs::just(std::move(v), std::move(cn));  in just()
1746         -> decltype(rxs::start_with(std::move(o), std::move(v0), std::move(vn)...)) {  in start_with()
1747         return      rxs::start_with(std::move(o), std::move(v0), std::move(vn)...);  in start_with()
1769         -> decltype(rxs::error<T>(std::forward<Exception>(e))) {  in error()
1770         return      rxs::error<T>(std::forward<Exception>(e));  in error()
1776         -> decltype(rxs::error<T>(std::forward<Exception>(e), std::move(cn))) {  in error()
1777         return      rxs::error<T>(std::forward<Exception>(e), std::move(cn));  in error()
1784         -> decltype(rxs::scope(std::move(rf), std::move(of))) {  in scope()
1785         return      rxs::scope(std::move(rf), std::move(of));  in scope()