Home
last modified time | relevance | path

Searched refs:operator_factory (Results 1 – 25 of 59) sorted by relevance

123

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-reduce.hpp354 -> operator_factory<reduce_tag, AN...> { in reduce()
355 return operator_factory<reduce_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in reduce()
362 -> operator_factory<reduce_tag, AN...> { in accumulate()
363 return operator_factory<reduce_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in accumulate()
379 -> operator_factory<first_tag> { in first()
380 return operator_factory<first_tag>(std::tuple<>{}); in first()
396 -> operator_factory<last_tag> { in last()
397 return operator_factory<last_tag>(std::tuple<>{}); in last()
413 -> operator_factory<reduce_tag, int, rxu::count, rxu::detail::take_at<0>> { in count()
414 …return operator_factory<reduce_tag, int, rxu::count, rxu::detail::take_at<0>>(std::make_tuple(0, r… in count()
[all …]
Drx-any.hpp122 -> operator_factory<any_tag, AN...> { in any()
123 return operator_factory<any_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in any()
140 -> operator_factory<exists_tag, AN...> { in exists()
141 return operator_factory<exists_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in exists()
158 -> operator_factory<contains_tag, AN...> { in contains()
159 return operator_factory<contains_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in contains()
Drx-map.hpp106 -> operator_factory<map_tag, AN...> { in map()
107 return operator_factory<map_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in map()
114 -> operator_factory<map_tag, AN...> { in transform()
115 return operator_factory<map_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in transform()
Drx-on_error_resume_next.hpp111 -> operator_factory<on_error_resume_next_tag, AN...> { in on_error_resume_next()
112 …return operator_factory<on_error_resume_next_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in on_error_resume_next()
119 -> operator_factory<on_error_resume_next_tag, AN...> { in switch_on_error()
120 …return operator_factory<on_error_resume_next_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in switch_on_error()
Drx-publish.hpp66 -> operator_factory<publish_tag, AN...> { in publish()
67 return operator_factory<publish_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in publish()
85 -> operator_factory<publish_synchronized_tag, AN...> { in publish_synchronized()
86 …return operator_factory<publish_synchronized_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in publish_synchronized()
Drx-switch_if_empty.hpp109 -> operator_factory<switch_if_empty_tag, AN...> { in switch_if_empty()
110 return operator_factory<switch_if_empty_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in switch_if_empty()
127 -> operator_factory<default_if_empty_tag, AN...> { in default_if_empty()
128 return operator_factory<default_if_empty_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in default_if_empty()
Drx-all.hpp115 -> operator_factory<all_tag, AN...> { in all()
116 return operator_factory<all_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in all()
129 -> operator_factory<is_empty_tag, AN...> { in is_empty()
130 return operator_factory<is_empty_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in is_empty()
Drx-start_with.hpp54 -> operator_factory<start_with_tag, AN...> { in start_with()
55 return operator_factory<start_with_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in start_with()
Drx-connect_forever.hpp59 -> operator_factory<connect_forever_tag, AN...> { in connect_forever()
60 return operator_factory<connect_forever_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in connect_forever()
Drx-ignore_elements.hpp85 -> operator_factory<ignore_elements_tag, AN...> { in ignore_elements()
86 return operator_factory<ignore_elements_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in ignore_elements()
Drx-distinct.hpp89 -> operator_factory<distinct_tag, AN...> { in distinct()
90 return operator_factory<distinct_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in distinct()
Drx-skip_while.hpp103 -> operator_factory<skip_while_tag, AN...> { in skip_while()
104 return operator_factory<skip_while_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in skip_while()
Drx-finally.hpp105 -> operator_factory<finally_tag, AN...> { in finally()
106 return operator_factory<finally_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in finally()
Drx-repeat.hpp83 -> operator_factory<repeat_tag, AN...> { in repeat()
84 return operator_factory<repeat_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in repeat()
Drx-pairwise.hpp96 -> operator_factory<pairwise_tag, AN...> { in pairwise()
97 return operator_factory<pairwise_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in pairwise()
Drx-take_while.hpp101 -> operator_factory<take_while_tag, AN...> { in take_while()
102 return operator_factory<take_while_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in take_while()
Drx-retry.hpp79 -> operator_factory<retry_tag, AN...> { in retry()
80 return operator_factory<retry_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in retry()
Drx-element_at.hpp107 -> operator_factory<element_at_tag, AN...> { in element_at()
108 return operator_factory<element_at_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in element_at()
Drx-multicast.hpp93 -> operator_factory<multicast_tag, AN...> { in multicast()
94 return operator_factory<multicast_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in multicast()
Drx-filter.hpp107 -> operator_factory<filter_tag, AN...> { in filter()
108 return operator_factory<filter_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in filter()
Drx-flat_map.hpp245 -> operator_factory<flat_map_tag, AN...> { in flat_map()
246 return operator_factory<flat_map_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in flat_map()
253 -> operator_factory<flat_map_tag, AN...> { in merge_transform()
254 return operator_factory<flat_map_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in merge_transform()
Drx-scan.hpp110 -> operator_factory<scan_tag, AN...> { in scan()
111 return operator_factory<scan_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in scan()
Drx-take.hpp134 -> operator_factory<take_tag, AN...> { in take()
135 return operator_factory<take_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in take()
Drx-distinct_until_changed.hpp102 -> operator_factory<distinct_until_changed_tag, AN...> { in distinct_until_changed()
103 …return operator_factory<distinct_until_changed_tag, AN...>(std::make_tuple(std::forward<AN>(an)...… in distinct_until_changed()
Drx-skip.hpp131 -> operator_factory<skip_tag, AN...> { in skip()
132 return operator_factory<skip_tag, AN...>(std::make_tuple(std::forward<AN>(an)...)); in skip()

123