Home
last modified time | relevance | path

Searched refs:SourceValue (Results 1 – 25 of 55) sorted by relevance

123

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-replay.hpp103 class SourceValue = rxu::value_type_t<Observable>,
104 class Subject = rxsub::replay<SourceValue, identity_one_worker>,
105 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
106 class Result = connectable_observable<SourceValue, Multicast>
115 class SourceValue = rxu::value_type_t<Observable>,
116 class Subject = rxsub::replay<SourceValue, identity_one_worker>,
117 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
118 class Result = connectable_observable<SourceValue, Multicast>
128 class SourceValue = rxu::value_type_t<Observable>,
129 class Subject = rxsub::replay<SourceValue, rxu::decay_t<Coordination>>,
[all …]
Drx-publish.hpp97 class SourceValue = rxu::value_type_t<Observable>,
98 class Subject = rxsub::subject<SourceValue>,
99 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
100 class Result = connectable_observable<SourceValue, Multicast>
109 class SourceValue = rxu::value_type_t<Observable>,
110 class Subject = rxsub::subject<SourceValue>,
111 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
112 class Result = connectable_observable<SourceValue, Multicast>
121 class SourceValue = rxu::value_type_t<Observable>,
122 class Subject = rxsub::behavior<SourceValue>,
[all …]
Drx-switch_if_empty.hpp139 class SourceValue = rxu::value_type_t<Observable>,
140 class SwitchIfEmpty = rxo::detail::switch_if_empty<SourceValue, rxu::decay_t<BackupSource>>>
142 -> decltype(o.template lift<SourceValue>(SwitchIfEmpty(std::forward<BackupSource>(b)))) { in member()
143 return o.template lift<SourceValue>(SwitchIfEmpty(std::forward<BackupSource>(b))); in member()
160 class SourceValue = rxu::value_type_t<Observable>,
161 class BackupSource = decltype(rxs::from(std::declval<SourceValue>())),
162 class DefaultIfEmpty = rxo::detail::switch_if_empty<SourceValue, BackupSource>>
164 -> decltype(o.template lift<SourceValue>(DefaultIfEmpty(rxs::from(std::move(v))))) { in member()
165 return o.template lift<SourceValue>(DefaultIfEmpty(rxs::from(std::move(v)))); in member()
Drx-distinct_until_changed.hpp112 class SourceValue = rxu::value_type_t<Observable>,
115 … class DistinctUntilChanged = rxo::detail::distinct_until_changed<SourceValue, rxu::equal_to<>>>
117 -> decltype(o.template lift<SourceValue>(DistinctUntilChanged(rxu::equal_to<>()))) { in member()
118 return o.template lift<SourceValue>(DistinctUntilChanged(rxu::equal_to<>())); in member()
123 class SourceValue = rxu::value_type_t<Observable>,
126 … class DistinctUntilChanged = rxo::detail::distinct_until_changed<SourceValue, BinaryPredicate>>
128 …-> decltype(o.template lift<SourceValue>(DistinctUntilChanged(std::forward<BinaryPredicate>(pred))… in member()
129 … return o.template lift<SourceValue>(DistinctUntilChanged(std::forward<BinaryPredicate>(pred))); in member()
Drx-merge.hpp229 class SourceValue = rxu::value_type_t<Observable>,
230 … class Merge = rxo::detail::merge<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
231 class Value = rxu::value_type_t<SourceValue>,
242 class SourceValue = rxu::value_type_t<Observable>,
243 …class Merge = rxo::detail::merge<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Coordination>…
244 class Value = rxu::value_type_t<SourceValue>,
255 class SourceValue = observable<EmittedValue>,
256 class ObservableObservable = observable<SourceValue>,
257 …class Merge = typename rxu::defer_type<rxo::detail::merge, SourceValue, ObservableObservable, iden…
270 class SourceValue = observable<EmittedValue>,
[all …]
Drx-sample_time.hpp215 class SourceValue = rxu::value_type_t<Observable>,
216 …class SampleWithTime = rxo::detail::sample_with_time<SourceValue, rxu::decay_t<Duration>, identity…
218 …-> decltype(o.template lift<SourceValue>(SampleWithTime(std::forward<Duration>(d), identity_curren… in member()
219 …return o.template lift<SourceValue>(SampleWithTime(std::forward<Duration>(d), identity_curren… in member()
227 class SourceValue = rxu::value_type_t<Observable>,
228 …class SampleWithTime = rxo::detail::sample_with_time<SourceValue, rxu::decay_t<Duration>, rxu::dec…
230 …-> decltype(o.template lift<SourceValue>(SampleWithTime(std::forward<Duration>(d), std::forward<Co… in member()
231 …return o.template lift<SourceValue>(SampleWithTime(std::forward<Duration>(d), std::forward<Co… in member()
239 class SourceValue = rxu::value_type_t<Observable>,
240 …class SampleWithTime = rxo::detail::sample_with_time<SourceValue, rxu::decay_t<Duration>, rxu::dec…
[all …]
Drx-merge_delay_error.hpp243 class SourceValue = rxu::value_type_t<Observable>,
244 …class Merge = rxo::detail::merge_delay_error<SourceValue, rxu::decay_t<Observable>, identity_one_w…
245 class Value = rxu::value_type_t<SourceValue>,
256 class SourceValue = rxu::value_type_t<Observable>,
257 …class Merge = rxo::detail::merge_delay_error<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<C…
258 class Value = rxu::value_type_t<SourceValue>,
269 class SourceValue = observable<EmittedValue>,
270 class ObservableObservable = observable<SourceValue>,
271 …class Merge = typename rxu::defer_type<rxo::detail::merge_delay_error, SourceValue, ObservableObse…
284 class SourceValue = observable<EmittedValue>,
[all …]
Drx-amb.hpp237 class SourceValue = rxu::value_type_t<Observable>,
238 class Amb = rxo::detail::amb<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
239 class Value = rxu::value_type_t<SourceValue>,
250 class SourceValue = rxu::value_type_t<Observable>,
251 … class Amb = rxo::detail::amb<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Coordination>>,
252 class Value = rxu::value_type_t<SourceValue>,
263 class SourceValue = observable<EmittedValue>,
264 class ObservableObservable = observable<SourceValue>,
265 …class Amb = typename rxu::defer_type<rxo::detail::amb, SourceValue, ObservableObservable, identity…
278 class SourceValue = observable<EmittedValue>,
[all …]
Drx-delay.hpp196 class SourceValue = rxu::value_type_t<Observable>,
197 class delay = rxo::detail::delay<SourceValue, rxu::decay_t<Duration>, identity_one_worker>>
199 …-> decltype(o.template lift<SourceValue>(delay(std::forward<Duration>(d), identity_current_thread(… in member()
200 …return o.template lift<SourceValue>(delay(std::forward<Duration>(d), identity_current_thread(… in member()
208 class SourceValue = rxu::value_type_t<Observable>,
209 … class delay = rxo::detail::delay<SourceValue, rxu::decay_t<Duration>, rxu::decay_t<Coordination>>>
211 …-> decltype(o.template lift<SourceValue>(delay(std::forward<Duration>(d), std::forward<Coordinatio… in member()
212 …return o.template lift<SourceValue>(delay(std::forward<Duration>(d), std::forward<Coordinatio… in member()
220 class SourceValue = rxu::value_type_t<Observable>,
221 … class delay = rxo::detail::delay<SourceValue, rxu::decay_t<Duration>, rxu::decay_t<Coordination>>>
[all …]
Drx-concat.hpp248 class SourceValue = rxu::value_type_t<Observable>,
249 … class Concat = rxo::detail::concat<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
250 class Value = rxu::value_type_t<SourceValue>,
261 class SourceValue = rxu::value_type_t<Observable>,
262 …class Concat = rxo::detail::concat<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Coordinatio…
263 class Value = rxu::value_type_t<SourceValue>,
274 class SourceValue = observable<EmittedValue>,
275 class ObservableObservable = observable<SourceValue>,
276 …class Concat = typename rxu::defer_type<rxo::detail::concat, SourceValue, ObservableObservable, id…
289 class SourceValue = observable<EmittedValue>,
[all …]
Drx-timeout.hpp243 class SourceValue = rxu::value_type_t<Observable>,
244 … class Timeout = rxo::detail::timeout<SourceValue, rxu::decay_t<Duration>, identity_one_worker>>
246 …-> decltype(o.template lift<SourceValue>(Timeout(std::forward<Duration>(d), identity_current_threa… in member()
247 …return o.template lift<SourceValue>(Timeout(std::forward<Duration>(d), identity_current_threa… in member()
255 class SourceValue = rxu::value_type_t<Observable>,
256 …class Timeout = rxo::detail::timeout<SourceValue, rxu::decay_t<Duration>, rxu::decay_t<Coordinatio…
258 …-> decltype(o.template lift<SourceValue>(Timeout(std::forward<Duration>(d), std::forward<Coordinat… in member()
259 …return o.template lift<SourceValue>(Timeout(std::forward<Duration>(d), std::forward<Coordinat… in member()
267 class SourceValue = rxu::value_type_t<Observable>,
268 …class Timeout = rxo::detail::timeout<SourceValue, rxu::decay_t<Duration>, rxu::decay_t<Coordinatio…
[all …]
Drx-debounce.hpp227 class SourceValue = rxu::value_type_t<Observable>,
228 … class Debounce = rxo::detail::debounce<SourceValue, rxu::decay_t<Duration>, identity_one_worker>>
230 …-> decltype(o.template lift<SourceValue>(Debounce(std::forward<Duration>(d), identity_current_thre… in member()
231 …return o.template lift<SourceValue>(Debounce(std::forward<Duration>(d), identity_current_thre… in member()
239 class SourceValue = rxu::value_type_t<Observable>,
240 …class Debounce = rxo::detail::debounce<SourceValue, rxu::decay_t<Duration>, rxu::decay_t<Coordinat…
242 …-> decltype(o.template lift<SourceValue>(Debounce(std::forward<Duration>(d), std::forward<Coordina… in member()
243 …return o.template lift<SourceValue>(Debounce(std::forward<Duration>(d), std::forward<Coordina… in member()
251 class SourceValue = rxu::value_type_t<Observable>,
252 …class Debounce = rxo::detail::debounce<SourceValue, rxu::decay_t<Duration>, rxu::decay_t<Coordinat…
[all …]
Drx-distinct.hpp99 class SourceValue = rxu::value_type_t<Observable>,
102 is_hashable<SourceValue>>,
103 class Distinct = rxo::detail::distinct<SourceValue>>
105 -> decltype(o.template lift<SourceValue>(Distinct())) { in member()
106 return o.template lift<SourceValue>(Distinct()); in member()
Drx-timestamp.hpp118 class SourceValue = rxu::value_type_t<Observable>,
119 class Timestamp = rxo::detail::timestamp<SourceValue, identity_one_worker>,
121 class Value = std::pair<SourceValue, Clock>>
131 class SourceValue = rxu::value_type_t<Observable>,
132 class Timestamp = rxo::detail::timestamp<SourceValue, rxu::decay_t<Coordination>>,
134 class Value = std::pair<SourceValue, Clock>>
Drx-flat_map.hpp264 class SourceValue = rxu::value_type_t<Observable>,
265 class CollectionType = rxu::result_of_t<CollectionSelectorType(SourceValue)>,
271 class Value = rxu::result_of_t<ResultSelectorType(SourceValue, CollectionValueType)>,
280 class SourceValue = rxu::value_type_t<Observable>,
281 class CollectionType = rxu::result_of_t<CollectionSelectorType(SourceValue)>,
288 class Value = rxu::result_of_t<ResultSelectorType(SourceValue, CollectionValueType)>,
298 class SourceValue = rxu::value_type_t<Observable>,
299 class CollectionType = rxu::result_of_t<CollectionSelectorType(SourceValue)>,
306 class Value = rxu::result_of_t<ResultSelectorType(SourceValue, CollectionValueType)>,
315 class SourceValue = rxu::value_type_t<Observable>,
[all …]
Drx-all.hpp139 class SourceValue = rxu::value_type_t<Observable>,
142 class All = rxo::detail::all<SourceValue, rxu::decay_t<Predicate>>,
161 class SourceValue = rxu::value_type_t<Observable>,
164 class Predicate = std::function<bool(SourceValue)>,
165 class IsEmpty = rxo::detail::all<SourceValue, rxu::decay_t<Predicate>>,
169 return o.template lift<Value>(IsEmpty([](SourceValue) { return false; })); in member() argument
Drx-concat_map.hpp297 class SourceValue = rxu::value_type_t<Observable>,
298 class CollectionType = rxu::result_of_t<CollectionSelectorType(SourceValue)>,
304 class Value = rxu::result_of_t<ResultSelectorType(SourceValue, CollectionValueType)>,
313 class SourceValue = rxu::value_type_t<Observable>,
314 class CollectionType = rxu::result_of_t<CollectionSelectorType(SourceValue)>,
321 class Value = rxu::result_of_t<ResultSelectorType(SourceValue, CollectionValueType)>,
331 class SourceValue = rxu::value_type_t<Observable>,
332 class CollectionType = rxu::result_of_t<CollectionSelectorType(SourceValue)>,
339 class Value = rxu::result_of_t<ResultSelectorType(SourceValue, CollectionValueType)>,
348 class SourceValue = rxu::value_type_t<Observable>,
[all …]
Drx-group_by.hpp328 class SourceValue = rxu::value_type_t<Observable>,
329 …class Traits = rxo::detail::group_by_traits<SourceValue, rxu::decay_t<Observable>, KeySelector, Ma…
330 …class GroupBy = rxo::detail::group_by<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<KeySelec…
339 class SourceValue = rxu::value_type_t<Observable>,
340 …class Traits = rxo::detail::group_by_traits<SourceValue, rxu::decay_t<Observable>, KeySelector, Ma…
341 …class GroupBy = rxo::detail::group_by<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<KeySelec…
351 class SourceValue = rxu::value_type_t<Observable>,
352 …class Traits = rxo::detail::group_by_traits<SourceValue, rxu::decay_t<Observable>, KeySelector, Ma…
353 …class GroupBy = rxo::detail::group_by<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<KeySelec…
365 class SourceValue = rxu::value_type_t<Observable>,
[all …]
Drx-ignore_elements.hpp95 class SourceValue = rxu::value_type_t<Observable>,
98 class IgnoreElements = rxo::detail::ignore_elements<SourceValue>>
100 -> decltype(o.template lift<SourceValue>(IgnoreElements())) { in member()
101 return o.template lift<SourceValue>(IgnoreElements()); in member()
Drx-take_until.hpp223 class SourceValue = rxu::value_type_t<Observable>,
227 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
240 class SourceValue = rxu::value_type_t<Observable>,
244 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
254 class SourceValue = rxu::value_type_t<Observable>,
255 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
266 class SourceValue = rxu::value_type_t<Observable>,
267 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
Drx-skip_until.hpp215 class SourceValue = rxu::value_type_t<Observable>,
219 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
232 class SourceValue = rxu::value_type_t<Observable>,
236 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
246 class SourceValue = rxu::value_type_t<Observable>,
247 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
258 class SourceValue = rxu::value_type_t<Observable>,
259 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
Drx-switch_on_next.hpp215 class SourceValue = rxu::value_type_t<Observable>,
216 …class SwitchOnNext = rxo::detail::switch_on_next<SourceValue, rxu::decay_t<Observable>, identity_o…
217 class Value = rxu::value_type_t<SourceValue>,
228 class SourceValue = rxu::value_type_t<Observable>,
229 …class SwitchOnNext = rxo::detail::switch_on_next<SourceValue, rxu::decay_t<Observable>, rxu::decay…
230 class Value = rxu::value_type_t<SourceValue>,
Drx-repeat.hpp93 class SourceValue = rxu::value_type_t<Observable>,
94 class Repeat = rxo::detail::repeat::infinite<SourceValue, rxu::decay_t<Observable>>,
104 class SourceValue = rxu::value_type_t<Observable>,
105 …class Repeat = rxo::detail::repeat::finite<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Cou…
Drx-take_while.hpp111 class SourceValue = rxu::value_type_t<Observable>,
112 class TakeWhile = rxo::detail::take_while<SourceValue, rxu::decay_t<Predicate>>>
114 -> decltype(o.template lift<SourceValue>(TakeWhile(std::forward<Predicate>(p)))) { in member()
115 return o.template lift<SourceValue>(TakeWhile(std::forward<Predicate>(p))); in member()
Drx-finally.hpp115 class SourceValue = rxu::value_type_t<Observable>,
118 class Finally = rxo::detail::finally<SourceValue, rxu::decay_t<LastCall>>>
120 -> decltype(o.template lift<SourceValue>(Finally(std::forward<LastCall>(lc)))) { in member()
121 return o.template lift<SourceValue>(Finally(std::forward<LastCall>(lc))); in member()

123