Lines Matching full:an
117 template<class... AN>
118 static observable_type make(const Default&, AN&&... an) { in make()
119 return observable_type(type(std::forward<AN>(an)...)); in make()
127 template<class... AN>
128 static observable_type make(const observable_type& that, const AN&...) { in make()
139 template<class... AN>
140 static observable_type make(AN&&... an) { in make()
141 return observable_type(type(std::forward<AN>(an)...)); in make()
149 template<class... AN>
150 static observable_type make(const AN&...) { in make()
156 template<class Selector, class Default, template<class... TN> class SO, class... AN>
158 : public detail::resolve_observable<Selector::value, Default, rxu::defer_type<SO, AN...>>
172 static auto blocking_subscribe(const Obsvbl& source, bool do_rethrow, ArgN&&... an) in blocking_subscribe() argument
179 auto dest = make_subscriber<T>(std::forward<ArgN>(an)...); in blocking_subscribe()
227 /// \param an... - the arguments are passed to make_subscriber().
234 /// the `on_next`, `on_error`, `on_completed` methods can be supplied instead of an observer
238 auto subscribe(ArgN&&... an) const in subscribe()
240 return blocking_subscribe(source, false, std::forward<ArgN>(an)...); in subscribe()
252 /// \param an... - the arguments are passed to make_subscriber().
259 /// the `on_next`, `on_error`, `on_completed` methods can be supplied instead of an observer
263 auto subscribe_with_rethrow(ArgN&&... an) const in subscribe_with_rethrow()
265 return blocking_subscribe(source, true, std::forward<ArgN>(an)...); in subscribe_with_rethrow()
268 …/*! Return the first item emitted by this blocking_observable, or throw an std::runtime_error exce…
283 template<class... AN>
284 auto first(AN**...) -> delayed_type_t<T, AN...> const { in first() argument
293 static_assert(sizeof...(AN) == 0, "first() was passed too many arguments."); in first()
296 …/*! Return the last item emitted by this blocking_observable, or throw an std::runtime_error excep…
311 template<class... AN>
312 auto last(AN**...) -> delayed_type_t<T, AN...> const { in last() argument
319 static_assert(sizeof...(AN) == 0, "last() was passed too many arguments."); in last()
341 …/*! Return the sum of all items emitted by this blocking_observable, or throw an std::runtime_erro…
362 …/*! Return the average value of all items emitted by this blocking_observable, or throw an std::ru…
383 …/*! Return the max of all items emitted by this blocking_observable, or throw an std::runtime_erro…
404 …/*! Return the min of all items emitted by this blocking_observable, or throw an std::runtime_erro…
532 …alue || rxs::is_source<source_operator_type>::value, "observable must wrap an operator or source");
571 template<class... AN>
572 observable<T> as_dynamic(AN**...) const { in as_dynamic()
574 static_assert(sizeof...(AN) == 0, "as_dynamic() was passed too many arguments."); in as_dynamic()
579 template<class... AN>
580 auto ref_count(AN... an) const // ref_count(ConnectableObservable&&) in ref_count()
582 … -> decltype(observable_member(ref_count_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in ref_count()
585 … return observable_member(ref_count_tag{}, *this, std::forward<AN>(an)...);
590 template<class... AN>
591 blocking_observable<T, this_type> as_blocking(AN**...) const { in as_blocking()
593 static_assert(sizeof...(AN) == 0, "as_blocking() was passed too many arguments."); in as_blocking()
648 auto subscribe(ArgN&&... an) const in subscribe()
650 return detail_subscribe(make_subscriber<T>(std::forward<ArgN>(an)...)); in subscribe()
655 template<class... AN>
656 auto all(AN&&... an) const in all()
658 -> decltype(observable_member(all_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in all()
661 return observable_member(all_tag{}, *this, std::forward<AN>(an)...);
666 template<class... AN>
667 auto is_empty(AN&&... an) const in is_empty()
669 -> decltype(observable_member(is_empty_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in is_empty()
672 return observable_member(is_empty_tag{}, *this, std::forward<AN>(an)...);
677 template<class... AN>
678 auto any(AN&&... an) const in any()
680 -> decltype(observable_member(any_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in any()
683 return observable_member(any_tag{}, *this, std::forward<AN>(an)...);
688 template<class... AN>
689 auto exists(AN&&... an) const in exists()
691 -> decltype(observable_member(exists_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in exists()
694 return observable_member(exists_tag{}, *this, std::forward<AN>(an)...);
699 template<class... AN>
700 auto contains(AN&&... an) const in contains()
702 -> decltype(observable_member(contains_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in contains()
705 return observable_member(contains_tag{}, *this, std::forward<AN>(an)...);
710 template<class... AN>
711 auto filter(AN&&... an) const in filter()
713 -> decltype(observable_member(filter_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in filter()
716 return observable_member(filter_tag{}, *this, std::forward<AN>(an)...);
721 template<class... AN>
722 auto switch_if_empty(AN&&... an) const in switch_if_empty()
724 …> decltype(observable_member(switch_if_empty_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in switch_if_empty()
727 …eturn observable_member(switch_if_empty_tag{}, *this, std::forward<AN>(an)...);
732 template<class... AN>
733 auto default_if_empty(AN&&... an) const in default_if_empty()
735 … decltype(observable_member(default_if_empty_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in default_if_empty()
738 …turn observable_member(default_if_empty_tag{}, *this, std::forward<AN>(an)...);
743 template<class... AN>
744 auto sequence_equal(AN... an) const in sequence_equal()
746 …-> decltype(observable_member(sequence_equal_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in sequence_equal()
749 …return observable_member(sequence_equal_tag{}, *this, std::forward<AN>(an)...);
754 template<class... AN>
755 auto tap(AN&&... an) const in tap()
757 -> decltype(observable_member(tap_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in tap()
760 return observable_member(tap_tag{}, *this, std::forward<AN>(an)...);
765 template<class... AN>
766 auto time_interval(AN&&... an) const in time_interval()
768 … -> decltype(observable_member(time_interval_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in time_interval()
771 … return observable_member(time_interval_tag{}, *this, std::forward<AN>(an)...);
776 template<class... AN>
777 auto timeout(AN&&... an) const in timeout()
779 -> decltype(observable_member(timeout_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in timeout()
782 return observable_member(timeout_tag{}, *this, std::forward<AN>(an)...);
787 template<class... AN>
788 auto timestamp(AN&&... an) const in timestamp()
790 -> decltype(observable_member(timestamp_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in timestamp()
793 return observable_member(timestamp_tag{}, *this, std::forward<AN>(an)...);
798 template<class... AN>
799 auto finally(AN&&... an) const in finally()
801 -> decltype(observable_member(finally_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in finally()
804 return observable_member(finally_tag{}, *this, std::forward<AN>(an)...);
809 template<class... AN>
810 auto on_error_resume_next(AN&&... an) const in on_error_resume_next()
812 …ltype(observable_member(on_error_resume_next_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in on_error_resume_next()
815 …turn observable_member(on_error_resume_next_tag{}, *this, std::forward<AN>(an)...);
820 template<class... AN>
821 auto switch_on_error(AN&&... an) const in switch_on_error()
823 …ltype(observable_member(on_error_resume_next_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in switch_on_error()
826 …turn observable_member(on_error_resume_next_tag{}, *this, std::forward<AN>(an)...);
831 template<class... AN>
832 auto map(AN&&... an) const in map()
834 -> decltype(observable_member(map_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in map()
837 return observable_member(map_tag{}, *this, std::forward<AN>(an)...);
842 template<class... AN>
843 auto transform(AN&&... an) const in transform()
845 -> decltype(observable_member(map_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in transform()
848 return observable_member(map_tag{}, *this, std::forward<AN>(an)...);
853 template<class... AN>
854 auto debounce(AN&&... an) const in debounce()
856 -> decltype(observable_member(debounce_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in debounce()
859 return observable_member(debounce_tag{}, *this, std::forward<AN>(an)...);
864 template<class... AN>
865 auto delay(AN&&... an) const in delay()
867 -> decltype(observable_member(delay_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in delay()
870 return observable_member(delay_tag{}, *this, std::forward<AN>(an)...);
875 template<class... AN>
876 auto distinct(AN&&... an) const in distinct()
878 -> decltype(observable_member(distinct_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in distinct()
881 return observable_member(distinct_tag{}, *this, std::forward<AN>(an)...);
886 template<class... AN>
887 auto distinct_until_changed(AN&&... an) const in distinct_until_changed()
889 …ype(observable_member(distinct_until_changed_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in distinct_until_changed()
892 …rn observable_member(distinct_until_changed_tag{}, *this, std::forward<AN>(an)...);
897 template<class... AN>
898 auto element_at(AN&&... an) const in element_at()
900 -> decltype(observable_member(element_at_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in element_at()
903 return observable_member(element_at_tag{}, *this, std::forward<AN>(an)...);
908 template<class... AN>
909 auto window(AN&&... an) const in window()
911 -> decltype(observable_member(window_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in window()
914 return observable_member(window_tag{}, *this, std::forward<AN>(an)...);
919 template<class... AN>
920 auto window_with_time(AN&&... an) const in window_with_time()
922 …-> decltype(observable_member(window_with_time_tag{}, *(this_type*)nullptr, std::forward<AN>(an)..… in window_with_time()
925 … return observable_member(window_with_time_tag{}, *this, std::forward<AN>(an)...);
930 template<class... AN>
931 auto window_with_time_or_count(AN&&... an) const in window_with_time_or_count()
933 …(observable_member(window_with_time_or_count_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in window_with_time_or_count()
936 … observable_member(window_with_time_or_count_tag{}, *this, std::forward<AN>(an)...);
941 template<class... AN>
942 auto window_toggle(AN&&... an) const in window_toggle()
944 … -> decltype(observable_member(window_toggle_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in window_toggle()
947 … return observable_member(window_toggle_tag{}, *this, std::forward<AN>(an)...);
952 template<class... AN>
953 auto buffer(AN&&... an) const in buffer()
955 … -> decltype(observable_member(buffer_count_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in buffer()
958 … return observable_member(buffer_count_tag{}, *this, std::forward<AN>(an)...);
963 template<class... AN>
964 auto buffer_with_time(AN&&... an) const in buffer_with_time()
966 …-> decltype(observable_member(buffer_with_time_tag{}, *(this_type*)nullptr, std::forward<AN>(an)..… in buffer_with_time()
969 … return observable_member(buffer_with_time_tag{}, *this, std::forward<AN>(an)...);
974 template<class... AN>
975 auto buffer_with_time_or_count(AN&&... an) const in buffer_with_time_or_count()
977 …(observable_member(buffer_with_time_or_count_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in buffer_with_time_or_count()
980 … observable_member(buffer_with_time_or_count_tag{}, *this, std::forward<AN>(an)...);
985 template<class... AN>
986 auto switch_on_next(AN&&... an) const in switch_on_next()
988 …-> decltype(observable_member(switch_on_next_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in switch_on_next()
991 …return observable_member(switch_on_next_tag{}, *this, std::forward<AN>(an)...);
996 template<class... AN>
997 auto merge(AN... an) const in merge()
999 -> decltype(observable_member(merge_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in merge()
1002 return observable_member(merge_tag{}, *this, std::forward<AN>(an)...);
1007 template<class... AN>
1008 auto merge_delay_error(AN... an) const in merge_delay_error()
1010 …decltype(observable_member(merge_delay_error_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in merge_delay_error()
1013 …urn observable_member(merge_delay_error_tag{}, *this, std::forward<AN>(an)...);
1018 template<class... AN>
1019 auto amb(AN... an) const in amb()
1021 -> decltype(observable_member(amb_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in amb()
1024 return observable_member(amb_tag{}, *this, std::forward<AN>(an)...);
1029 template<class... AN>
1030 auto flat_map(AN&&... an) const in flat_map()
1032 … -> decltype(observable_member(flat_map_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in flat_map()
1035 … return observable_member(flat_map_tag{}, *this, std::forward<AN>(an)...);
1040 template<class... AN>
1041 auto merge_transform(AN&&... an) const in merge_transform()
1043 … -> decltype(observable_member(flat_map_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in merge_transform()
1046 … return observable_member(flat_map_tag{}, *this, std::forward<AN>(an)...);
1051 template<class... AN>
1052 auto concat(AN... an) const in concat()
1054 -> decltype(observable_member(concat_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in concat()
1057 return observable_member(concat_tag{}, *this, std::forward<AN>(an)...);
1062 template<class... AN>
1063 auto concat_map(AN&&... an) const in concat_map()
1065 … -> decltype(observable_member(concat_map_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in concat_map()
1068 … return observable_member(concat_map_tag{}, *this, std::forward<AN>(an)...);
1073 template<class... AN>
1074 auto concat_transform(AN&&... an) const in concat_transform()
1076 … -> decltype(observable_member(concat_map_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in concat_transform()
1079 … return observable_member(concat_map_tag{}, *this, std::forward<AN>(an)...);
1084 template<class... AN>
1085 auto with_latest_from(AN... an) const in with_latest_from()
1087 … decltype(observable_member(with_latest_from_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in with_latest_from()
1090 …turn observable_member(with_latest_from_tag{}, *this, std::forward<AN>(an)...);
1096 template<class... AN>
1097 auto combine_latest(AN... an) const in combine_latest()
1099 …-> decltype(observable_member(combine_latest_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in combine_latest()
1102 …return observable_member(combine_latest_tag{}, *this, std::forward<AN>(an)...);
1107 template<class... AN>
1108 auto zip(AN&&... an) const in zip()
1110 -> decltype(observable_member(zip_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in zip()
1113 return observable_member(zip_tag{}, *this, std::forward<AN>(an)...);
1118 template<class... AN>
1119 inline auto group_by(AN&&... an) const in group_by()
1121 … -> decltype(observable_member(group_by_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in group_by()
1124 … return observable_member(group_by_tag{}, *this, std::forward<AN>(an)...);
1129 template<class... AN>
1130 auto ignore_elements(AN&&... an) const in ignore_elements()
1132 …-> decltype(observable_member(ignore_elements_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...… in ignore_elements()
1135 … return observable_member(ignore_elements_tag{}, *this, std::forward<AN>(an)...);
1140 template<class... AN>
1141 auto multicast(AN&&... an) const in multicast()
1143 … -> decltype(observable_member(multicast_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in multicast()
1146 … return observable_member(multicast_tag{}, *this, std::forward<AN>(an)...);
1151 template<class... AN>
1152 auto publish(AN&&... an) const in publish()
1154 -> decltype(observable_member(publish_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in publish()
1157 return observable_member(publish_tag{}, *this, std::forward<AN>(an)...);
1162 template<class... AN>
1163 auto publish_synchronized(AN&&... an) const in publish_synchronized()
1165 …ltype(observable_member(publish_synchronized_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in publish_synchronized()
1168 … observable_member(publish_synchronized_tag{}, *this, std::forward<AN>(an)...);
1173 template<class... AN>
1174 auto replay(AN&&... an) const in replay()
1176 -> decltype(observable_member(replay_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in replay()
1179 return observable_member(replay_tag{}, *this, std::forward<AN>(an)...);
1184 template<class... AN>
1185 auto subscribe_on(AN&&... an) const in subscribe_on()
1187 … -> decltype(observable_member(subscribe_on_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in subscribe_on()
1190 … return observable_member(subscribe_on_tag{}, *this, std::forward<AN>(an)...);
1195 template<class... AN>
1196 auto observe_on(AN&&... an) const in observe_on()
1198 … -> decltype(observable_member(observe_on_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in observe_on()
1201 … return observable_member(observe_on_tag{}, *this, std::forward<AN>(an)...);
1206 template<class... AN>
1207 auto reduce(AN&&... an) const in reduce()
1209 -> decltype(observable_member(reduce_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in reduce()
1212 return observable_member(reduce_tag{}, *this, std::forward<AN>(an)...);
1217 template<class... AN>
1218 auto accumulate(AN&&... an) const in accumulate()
1220 -> decltype(observable_member(reduce_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in accumulate()
1223 return observable_member(reduce_tag{}, *this, std::forward<AN>(an)...);
1228 template<class... AN>
1229 auto first(AN**...) const in first()
1231 … -> decltype(observable_member(delayed_type<first_tag, AN...>::value(), *(this_type*)nullptr)) in first()
1234 … return observable_member(delayed_type<first_tag, AN...>::value(), *this); in first()
1235 static_assert(sizeof...(AN) == 0, "first() was passed too many arguments."); in first()
1240 template<class... AN>
1241 auto last(AN**...) const in last()
1243 -> decltype(observable_member(delayed_type<last_tag, AN...>::value(), *(this_type*)nullptr)) in last()
1246 return observable_member(delayed_type<last_tag, AN...>::value(), *this); in last()
1247 static_assert(sizeof...(AN) == 0, "last() was passed too many arguments."); in last()
1252 template<class... AN>
1253 auto count(AN**...) const in count()
1255 …-> decltype(observable_member(delayed_type<reduce_tag, AN...>::value(), *(this_type*)nullptr, 0, r… in count()
1258 …return observable_member(delayed_type<reduce_tag, AN...>::value(), *this, 0, r… in count()
1259 static_assert(sizeof...(AN) == 0, "count() was passed too many arguments."); in count()
1264 template<class... AN>
1265 auto sum(AN**...) const in sum()
1267 -> decltype(observable_member(delayed_type<sum_tag, AN...>::value(), *(this_type*)nullptr)) in sum()
1270 return observable_member(delayed_type<sum_tag, AN...>::value(), *this); in sum()
1271 static_assert(sizeof...(AN) == 0, "sum() was passed too many arguments."); in sum()
1276 template<class... AN>
1277 auto average(AN**...) const in average()
1279 … -> decltype(observable_member(delayed_type<average_tag, AN...>::value(), *(this_type*)nullptr)) in average()
1282 … return observable_member(delayed_type<average_tag, AN...>::value(), *this); in average()
1283 static_assert(sizeof...(AN) == 0, "average() was passed too many arguments."); in average()
1288 template<class... AN>
1289 auto max(AN**...) const in max()
1291 -> decltype(observable_member(delayed_type<max_tag, AN...>::value(), *(this_type*)nullptr)) in max()
1294 return observable_member(delayed_type<max_tag, AN...>::value(), *this); in max()
1295 static_assert(sizeof...(AN) == 0, "max() was passed too many arguments."); in max()
1300 template<class... AN>
1301 auto min(AN**...) const in min()
1303 -> decltype(observable_member(delayed_type<min_tag, AN...>::value(), *(this_type*)nullptr)) in min()
1306 return observable_member(delayed_type<min_tag, AN...>::value(), *this); in min()
1307 static_assert(sizeof...(AN) == 0, "min() was passed too many arguments."); in min()
1312 template<class... AN>
1313 auto scan(AN... an) const in scan()
1315 -> decltype(observable_member(scan_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in scan()
1318 return observable_member(scan_tag{}, *this, std::forward<AN>(an)...);
1323 template<class... AN>
1324 auto sample_with_time(AN&&... an) const in sample_with_time()
1326 … decltype(observable_member(sample_with_time_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in sample_with_time()
1329 …turn observable_member(sample_with_time_tag{}, *this, std::forward<AN>(an)...);
1334 template<class... AN>
1335 auto skip(AN... an) const in skip()
1337 -> decltype(observable_member(skip_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in skip()
1340 return observable_member(skip_tag{}, *this, std::forward<AN>(an)...);
1345 template<class... AN>
1346 auto skip_while(AN... an) const in skip_while()
1348 … -> decltype(observable_member(skip_while_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in skip_while()
1351 … return observable_member(skip_while_tag{}, *this, std::forward<AN>(an)...);
1356 template<class... AN>
1357 auto skip_last(AN... an) const in skip_last()
1359 … -> decltype(observable_member(skip_last_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in skip_last()
1362 … return observable_member(skip_last_tag{}, *this, std::forward<AN>(an)...);
1367 template<class... AN>
1368 auto skip_until(AN... an) const in skip_until()
1370 … -> decltype(observable_member(skip_until_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in skip_until()
1373 … return observable_member(skip_until_tag{}, *this, std::forward<AN>(an)...);
1378 template<class... AN>
1379 auto take(AN... an) const in take()
1381 -> decltype(observable_member(take_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in take()
1384 return observable_member(take_tag{}, *this, std::forward<AN>(an)...);
1389 template<class... AN>
1390 auto take_last(AN&&... an) const in take_last()
1392 … -> decltype(observable_member(take_last_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in take_last()
1395 … return observable_member(take_last_tag{}, *this, std::forward<AN>(an)...);
1400 template<class... AN>
1401 auto take_until(AN&&... an) const in take_until()
1403 … -> decltype(observable_member(take_until_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in take_until()
1406 … return observable_member(take_until_tag{}, *this, std::forward<AN>(an)...);
1411 template<class... AN>
1412 auto take_while(AN&&... an) const in take_while()
1414 … -> decltype(observable_member(take_while_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in take_while()
1417 … return observable_member(take_while_tag{}, *this, std::forward<AN>(an)...);
1422 template<class... AN>
1423 auto repeat(AN... an) const in repeat()
1425 -> decltype(observable_member(repeat_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in repeat()
1428 return observable_member(repeat_tag{}, *this, std::forward<AN>(an)...);
1433 template<class... AN>
1434 auto retry(AN... an) const in retry()
1436 -> decltype(observable_member(retry_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in retry()
1439 …urn observable_member(retry_tag{}, *(this_type*)this, std::forward<AN>(an)...);
1444 template<class... AN>
1445 auto start_with(AN... an) const in start_with()
1447 … -> decltype(observable_member(start_with_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in start_with()
1450 … return observable_member(start_with_tag{}, *this, std::forward<AN>(an)...);
1455 template<class... AN>
1456 auto pairwise(AN... an) const in pairwise()
1458 … -> decltype(observable_member(pairwise_tag{}, *(this_type*)nullptr, std::forward<AN>(an)...)) in pairwise()
1461 … return observable_member(pairwise_tag{}, *this, std::forward<AN>(an)...);
1481 …ed as ```rxcpp::observable<>```, this is a collection of factory methods that return an observable.
1491 \par Create an observable that emits a range of values
1497 \par Create an observable that emits nothing / generates an error / immediately completes
1507 \par Create an observable that generates new observable for each subscriber
1513 \par Create an observable that emits items every specified interval of time
1519 \par Create an observable that emits items in the specified interval of time
1525 \par Create an observable that emits all items from a collection
1531 \par Create an observable that emits a set of specified items
1537 \par Create an observable that emits a single item
1543 \par Create an observable that emits a set of items and then subscribes to another observable
1549 …\par Create an observable that generates a new observable based on a generated resource for each s…
1616 template<class... AN>
1617 static auto interval(rxsc::scheduler::clock_type::duration period, AN**...) in interval() argument
1620 static_assert(sizeof...(AN) == 0, "interval(period) was passed too many arguments."); in interval()
1631 template<class... AN>
1632 …::scheduler::clock_type::time_point initial, rxsc::scheduler::clock_type::duration period, AN**...) in interval() argument
1635 … static_assert(sizeof...(AN) == 0, "interval(initial, period) was passed too many arguments."); in interval()
1647 template<class... AN>
1648 static auto timer(rxsc::scheduler::clock_type::time_point at, AN**...) in timer() argument
1651 static_assert(sizeof...(AN) == 0, "timer(at) was passed too many arguments."); in timer()
1655 template<class... AN>
1656 static auto timer(rxsc::scheduler::clock_type::duration after, AN**...) in timer() argument
1659 static_assert(sizeof...(AN) == 0, "timer(after) was passed too many arguments."); in timer()