Lines Matching refs:an
118 static observable_type make(const Default&, AN&&... an) { in make()
119 return observable_type(type(std::forward<AN>(an)...)); in make()
140 static observable_type make(AN&&... an) { in make()
141 return observable_type(type(std::forward<AN>(an)...)); in make()
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()
238 auto subscribe(ArgN&&... an) const in subscribe()
240 return blocking_subscribe(source, false, std::forward<ArgN>(an)...); in subscribe()
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()
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)...);
648 auto subscribe(ArgN&&... an) const in subscribe()
650 return detail_subscribe(make_subscriber<T>(std::forward<ArgN>(an)...)); in subscribe()
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);
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)...);