| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-replay.hpp | 98 struct member_overload<replay_tag> struct
108 static Result member(Observable&& o) { in member()
120 static Result member(Observable&& o, composite_subscription cs) { in member()
133 …t member(Observable&& o, Coordination&& cn, composite_subscription cs = composite_subscription()) { in member()
146 … Result member(Observable&& o, Count count, composite_subscription cs = composite_subscription()) { in member()
160 …rvable&& o, Count count, Coordination&& cn, composite_subscription cs = composite_subscription()) { in member()
174 …Result member(Observable&& o, Duration&& d, composite_subscription cs = composite_subscription()) { in member()
189 …vable&& o, Duration&& d, Coordination&& cn, composite_subscription cs = composite_subscription()) { in member()
204 …(Observable&& o, Count count, Duration&& d, composite_subscription cs = composite_subscription()) { in member()
220 …unt count, Duration&& d, Coordination&& cn, composite_subscription cs = composite_subscription()) { in member()
[all …]
|
| D | rx-publish.hpp | 92 struct member_overload<publish_tag> struct
102 static Result member(Observable&& o) { in member()
114 static Result member(Observable&& o, composite_subscription cs) { in member()
126 …atic Result member(Observable&& o, T first, composite_subscription cs = composite_subscription()) { in member()
131 static operators::detail::publish_invalid_t<AN...> member(AN...) { in member()
139 struct member_overload<publish_synchronized_tag> struct
150 …t member(Observable&& o, Coordination&& cn, composite_subscription cs = composite_subscription()) { in member()
155 static operators::detail::publish_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-reduce.hpp | 504 struct member_overload<reduce_tag> struct
511 static Result member(Observable&& o, Seed&& s, Accumulator&& a, ResultSelector&& r) in member()
521 static Result member(Observable&& o, Seed&& s, Accumulator&& a) in member()
527 static operators::detail::reduce_invalid_t<AN...> member(AN...) { in member()
535 struct member_overload<first_tag> struct
547 static Result member(Observable&& o) in member()
553 static operators::detail::reduce_invalid_t<AN...> member(AN...) { in member()
561 struct member_overload<last_tag> struct
572 static Result member(Observable&& o) in member()
578 static operators::detail::reduce_invalid_t<AN...> member(AN...) { in member()
[all …]
|
| D | rx-any.hpp | 165 struct member_overload<any_tag> struct
173 static auto member(Observable&& o, Predicate&& p) in member()
179 static operators::detail::any_invalid_t<AN...> member(const AN&...) { in member()
187 struct member_overload<exists_tag> struct
193 static operators::detail::any_invalid_t<AN...> member(const AN&...) { in member()
201 struct member_overload<contains_tag> struct
210 static auto member(Observable&& o, T&& value) in member()
216 static operators::detail::any_invalid_t<AN...> member(const AN&...) { in member()
|
| D | rx-repeat.hpp | 90 struct member_overload<repeat_tag> { struct
97 static Result member(Observable&& o) { in member()
108 static Result member(Observable&& o, Count&& c) { in member()
113 static operators::detail::repeat_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-retry.hpp | 86 struct member_overload<retry_tag> struct
95 static Result member(Observable&& o) { in member()
107 static Result member(Observable&& o, Count&& c) { in member()
112 static operators::detail::retry_invalid_t<AN...> member(const AN&...) { in member()
|
| D | rx-switch_if_empty.hpp | 134 struct member_overload<switch_if_empty_tag> struct
141 static auto member(Observable&& o, BackupSource&& b) in member()
147 static operators::detail::switch_if_empty_invalid_t<AN...> member(AN...) { in member()
155 struct member_overload<default_if_empty_tag> struct
163 static auto member(Observable&& o, Value v) in member()
169 static operators::detail::switch_if_empty_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-all.hpp | 136 struct member_overload<all_tag> struct
144 static auto member(Observable&& o, Predicate&& p) in member()
150 static operators::detail::all_invalid_t<AN...> member(const AN&...) { in member()
158 struct member_overload<is_empty_tag> struct
167 static auto member(Observable&& o) in member()
173 static operators::detail::all_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-start_with.hpp | 61 struct member_overload<start_with_tag> struct
68 static auto member(Observable&& o, Value0&& v0, ValueN&&... vn) in member()
75 static operators::detail::start_with_invalid_t<AN...> member(const AN&...) { in member()
|
| D | rx-connect_forever.hpp | 66 struct member_overload<connect_forever_tag> struct
76 static Result member(ConnectableObservable&& o) { in member()
81 static operators::detail::connect_forever_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-merge.hpp | 224 struct member_overload<merge_tag> struct
234 static Result member(Observable&& o) { in member()
247 static Result member(Observable&& o, Coordination&& cn) { in member()
261 static Result member(Observable&& o, Value0&& v0, ValueN&&... vn) { in member()
276 static Result member(Observable&& o, Coordination&& cn, Value0&& v0, ValueN&&... vn) { in member()
281 static operators::detail::merge_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-merge_delay_error.hpp | 238 struct member_overload<merge_delay_error_tag> struct
248 static Result member(Observable&& o) { in member()
261 static Result member(Observable&& o, Coordination&& cn) { in member()
275 static Result member(Observable&& o, Value0&& v0, ValueN&&... vn) { in member()
290 static Result member(Observable&& o, Coordination&& cn, Value0&& v0, ValueN&&... vn) { in member()
295 static operators::detail::merge_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-take_until.hpp | 217 struct member_overload<take_until_tag> struct
230 static Result member(Observable&& o, TimePoint&& when) { in member()
247 static Result member(Observable&& o, TimePoint&& when, Coordination cn) { in member()
258 static Result member(Observable&& o, TriggerObservable&& t) { in member()
270 static Result member(Observable&& o, TriggerObservable&& t, Coordination&& cn) { in member()
275 static operators::detail::take_until_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-skip_until.hpp | 209 struct member_overload<skip_until_tag> struct
222 static Result member(Observable&& o, TimePoint&& when) { in member()
239 static Result member(Observable&& o, TimePoint&& when, Coordination cn) { in member()
250 static Result member(Observable&& o, TriggerObservable&& t) { in member()
262 static Result member(Observable&& o, TriggerObservable&& t, Coordination&& cn) { in member()
267 static operators::detail::skip_until_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-amb.hpp | 232 struct member_overload<amb_tag> struct
242 static Result member(Observable&& o) { in member()
255 static Result member(Observable&& o, Coordination&& cn) { in member()
269 static Result member(Observable&& o, Value0&& v0, ValueN&&... vn) { in member()
284 static Result member(Observable&& o, Coordination&& cn, Value0&& v0, ValueN&&... vn) { in member()
289 static operators::detail::amb_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-concat.hpp | 243 struct member_overload<concat_tag> struct
253 static Result member(Observable&& o) { in member()
266 static Result member(Observable&& o, Coordination&& cn) { in member()
280 static Result member(Observable&& o, Value0&& v0, ValueN&&... vn) { in member()
295 static Result member(Observable&& o, Coordination&& cn, Value0&& v0, ValueN&&... vn) { in member()
300 static operators::detail::concat_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-distinct_until_changed.hpp | 109 struct member_overload<distinct_until_changed_tag> struct
116 static auto member(Observable&& o) in member()
127 static auto member(Observable&& o, BinaryPredicate&& pred) in member()
133 static operators::detail::distinct_until_changed_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-timestamp.hpp | 113 struct member_overload<timestamp_tag> struct
122 static auto member(Observable&& o) in member()
135 static auto member(Observable&& o, Coordination&& cn) in member()
141 static operators::detail::timestamp_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-sequence_equal.hpp | 218 struct member_overload<sequence_equal_tag> struct
228 static Result member(Observable&& o, OtherObservable&& t) { in member()
242 static Result member(Observable&& o, OtherObservable&& t, BinaryPredicate&& pred) { in member()
255 static Result member(Observable&& o, OtherObservable&& t, Coordination&& cn) { in member()
268 …tic Result member(Observable&& o, OtherObservable&& t, BinaryPredicate&& pred, Coordination&& cn) { in member()
273 static operators::detail::sequence_equal_invalid_t<AN...> member(const AN&...) { in member()
|
| D | rx-buffer_count.hpp | 144 struct member_overload<buffer_count_tag> struct
152 static auto member(Observable&& o, int count, int skip) in member()
163 static auto member(Observable&& o, int count) in member()
169 static operators::detail::buffer_count_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-time_interval.hpp | 119 struct member_overload<time_interval_tag> struct
127 static auto member(Observable&& o) in member()
139 static auto member(Observable&& o, Coordination&& cn) in member()
145 static operators::detail::time_interval_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-flat_map.hpp | 260 struct member_overload<flat_map_tag> struct
274 static Result member(Observable&& o, CollectionSelector&& s) { in member()
291 static Result member(Observable&& o, CollectionSelector&& s, Coordination&& cn) { in member()
309 static Result member(Observable&& o, CollectionSelector&& s, ResultSelector&& rs) { in member()
326 …tic Result member(Observable&& o, CollectionSelector&& s, ResultSelector&& rs, Coordination&& cn) { in member()
331 static operators::detail::flat_map_invalid_t<AN...> member(AN...) { in member()
|
| D | rx-combine_latest.hpp | 250 struct member_overload<combine_latest_tag> struct
258 static Result member(Observable&& o, ObservableN&&... on) in member()
271 static Result member(Observable&& o, Selector&& s, ObservableN&&... on) in member()
283 static Result member(Observable&& o, Coordination&& cn, ObservableN&&... on) in member()
297 static Result member(Observable&& o, Coordination&& cn, Selector&& s, ObservableN&&... on) in member()
303 static operators::detail::combine_latest_invalid_t<AN...> member(const AN&...) { in member()
|
| D | rx-with_latest_from.hpp | 250 struct member_overload<with_latest_from_tag> struct
258 static Result member(Observable&& o, ObservableN&&... on) in member()
271 static Result member(Observable&& o, Selector&& s, ObservableN&&... on) in member()
283 static Result member(Observable&& o, Coordination&& cn, ObservableN&&... on) in member()
297 static Result member(Observable&& o, Coordination&& cn, Selector&& s, ObservableN&&... on) in member()
303 static operators::detail::with_latest_from_invalid_t<AN...> member(const AN&...) { in member()
|
| D | rx-ignore_elements.hpp | 92 struct member_overload<ignore_elements_tag> struct
99 static auto member(Observable&& o) in member()
105 static operators::detail::ignore_elements_invalid_t<AN...> member(AN...) { in member()
|