| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-timer.hpp | 49 typedef rxu::decay_t<Coordination> coordination_type; typedef
50 typedef typename coordination_type::coordinator_type coordinator_type;
54 timer_initial_type(rxsc::scheduler::clock_type::time_point t, coordination_type cn) in timer_initial_type()
60 coordination_type coordination;
64 timer(rxsc::scheduler::clock_type::time_point t, coordination_type cn) in timer()
68 timer(rxsc::scheduler::clock_type::duration p, coordination_type cn) in timer()
|
| D | rx-error.hpp | 43 typedef rxu::decay_t<Coordination> coordination_type; typedef
45 typedef typename coordination_type::coordinator_type coordinator_type;
49 error_initial_type(rxu::error_ptr e, coordination_type cn) in error_initial_type()
55 coordination_type coordination;
59 error(rxu::error_ptr e, coordination_type cn) in error()
|
| D | rx-range.hpp | 42 typedef rxu::decay_t<Coordination> coordination_type; typedef
43 typedef typename coordination_type::coordinator_type coordinator_type;
47 range_state_type(T f, T l, std::ptrdiff_t s, coordination_type cn) in range_state_type()
57 coordination_type coordination;
60 range(T f, T l, std::ptrdiff_t s, coordination_type cn) in range()
|
| D | rx-interval.hpp | 49 typedef rxu::decay_t<Coordination> coordination_type; typedef
50 typedef typename coordination_type::coordinator_type coordinator_type;
54 …scheduler::clock_type::time_point i, rxsc::scheduler::clock_type::duration p, coordination_type cn) in interval_initial_type()
62 coordination_type coordination;
66 …scheduler::clock_type::time_point i, rxsc::scheduler::clock_type::duration p, coordination_type cn) in interval()
|
| D | rx-iterate.hpp | 66 typedef rxu::decay_t<Coordination> coordination_type; typedef
67 typedef typename coordination_type::coordinator_type coordinator_type;
74 iterate_initial_type(collection_type c, coordination_type cn) in iterate_initial_type()
80 coordination_type coordination;
84 iterate(collection_type c, coordination_type cn) in iterate()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-time_interval.hpp | 46 typedef rxu::decay_t<Coordination> coordination_type; typedef
49 time_interval_values(coordination_type c) in time_interval_values()
54 coordination_type coordination;
58 time_interval(coordination_type coordination) in time_interval()
72 coordination_type coord;
75 time_interval_observer(dest_type d, coordination_type coordination) in time_interval_observer()
|
| D | rx-timestamp.hpp | 45 typedef rxu::decay_t<Coordination> coordination_type; typedef
48 timestamp_values(coordination_type c) in timestamp_values()
53 coordination_type coordination;
57 timestamp(coordination_type coordination) in timestamp()
70 coordination_type coord;
72 timestamp_observer(dest_type d, coordination_type coordination) in timestamp_observer()
|
| D | rx-subscribe_on.hpp | 48 typedef rxu::decay_t<Coordination> coordination_type; typedef
49 typedef typename coordination_type::coordinator_type coordinator_type;
55 subscribe_on_values(source_type s, coordination_type sf) in subscribe_on_values()
61 coordination_type coordination;
70 subscribe_on(source_type s, coordination_type sf) in subscribe_on()
|
| D | rx-combine_latest.hpp | 96 typedef rxu::decay_t<Coordination> coordination_type; typedef
113 typedef typename traits::coordination_type coordination_type; typedef
114 typedef typename coordination_type::coordinator_type coordinator_type;
118 values(tuple_source_type o, selector_type s, coordination_type sf) in values()
126 coordination_type coordination;
130 combine_latest(coordination_type sf, selector_type s, tuple_source_type ts) in combine_latest()
|
| D | rx-with_latest_from.hpp | 96 typedef rxu::decay_t<Coordination> coordination_type; typedef
113 typedef typename traits::coordination_type coordination_type; typedef
114 typedef typename coordination_type::coordinator_type coordinator_type;
118 values(tuple_source_type o, selector_type s, coordination_type sf) in values()
126 coordination_type coordination;
130 with_latest_from(coordination_type sf, selector_type s, tuple_source_type ts) in with_latest_from()
|
| D | rx-switch_on_next.hpp | 58 typedef rxu::decay_t<Coordination> coordination_type; typedef
59 typedef typename coordination_type::coordinator_type coordinator_type;
63 values(source_operator_type o, coordination_type sf) in values()
69 coordination_type coordination;
73 switch_on_next(const source_type& o, coordination_type sf) in switch_on_next()
|
| D | rx-zip.hpp | 130 typedef rxu::decay_t<Coordination> coordination_type; typedef
147 typedef typename traits::coordination_type coordination_type; typedef
148 typedef typename coordination_type::coordinator_type coordinator_type;
152 values(tuple_source_type o, selector_type s, coordination_type sf) in values()
160 coordination_type coordination;
164 zip(coordination_type sf, selector_type s, tuple_source_type ts) in zip()
|
| D | rx-flat_map.hpp | 57 typedef rxu::decay_t<Coordination> coordination_type; typedef
100 typedef typename traits::coordination_type coordination_type; typedef
101 typedef typename coordination_type::coordinator_type coordinator_type;
105 … values(source_type o, collection_selector_type s, result_selector_type rs, coordination_type sf) in values()
115 coordination_type coordination;
119 … flat_map(source_type o, collection_selector_type s, result_selector_type rs, coordination_type sf) in flat_map()
|
| D | rx-concat_map.hpp | 57 typedef rxu::decay_t<Coordination> coordination_type; typedef
102 typedef typename traits::coordination_type coordination_type; typedef
103 typedef typename coordination_type::coordinator_type coordinator_type;
107 … values(source_type o, collection_selector_type s, result_selector_type rs, coordination_type sf) in values()
117 coordination_type coordination;
123 …oncat_map(source_type o, collection_selector_type s, result_selector_type rs, coordination_type sf) in concat_map()
|
| D | rx-merge.hpp | 79 typedef rxu::decay_t<Coordination> coordination_type; typedef
80 typedef typename coordination_type::coordinator_type coordinator_type;
84 values(source_operator_type o, coordination_type sf) in values()
90 coordination_type coordination;
94 merge(const source_type& o, coordination_type sf) in merge()
|
| D | rx-take_until.hpp | 63 typedef rxu::decay_t<Coordination> coordination_type; typedef
64 typedef typename coordination_type::coordinator_type coordinator_type;
67 values(source_type s, trigger_source_type t, coordination_type sf) in values()
75 coordination_type coordination;
79 take_until(source_type s, trigger_source_type t, coordination_type sf) in take_until()
|
| D | rx-sample_time.hpp | 47 typedef rxu::decay_t<Coordination> coordination_type; typedef
48 typedef typename coordination_type::coordinator_type coordinator_type;
53 sample_with_time_value(duration_type p, coordination_type c) in sample_with_time_value()
59 coordination_type coordination;
63 sample_with_time(duration_type period, coordination_type coordination) in sample_with_time()
|
| D | rx-merge_delay_error.hpp | 72 typedef rxu::decay_t<Coordination> coordination_type; typedef
73 typedef typename coordination_type::coordinator_type coordinator_type;
77 values(source_operator_type o, coordination_type sf) in values()
83 coordination_type coordination;
87 merge_delay_error(const source_type& o, coordination_type sf) in merge_delay_error()
|
| D | rx-skip_until.hpp | 53 typedef rxu::decay_t<Coordination> coordination_type; typedef
54 typedef typename coordination_type::coordinator_type coordinator_type;
57 values(source_type s, trigger_source_type t, coordination_type sf) in values()
65 coordination_type coordination;
69 skip_until(source_type s, trigger_source_type t, coordination_type sf) in skip_until()
|
| D | rx-amb.hpp | 75 typedef rxu::decay_t<Coordination> coordination_type; typedef
76 typedef typename coordination_type::coordinator_type coordinator_type;
80 values(source_operator_type o, coordination_type sf) in values()
86 coordination_type coordination;
90 amb(const source_type& o, coordination_type sf) in amb()
|
| D | rx-delay.hpp | 47 typedef rxu::decay_t<Coordination> coordination_type; typedef
48 typedef typename coordination_type::coordinator_type coordinator_type;
53 delay_values(duration_type p, coordination_type c) in delay_values()
59 coordination_type coordination;
63 delay(duration_type period, coordination_type coordination) in delay()
|
| D | rx-concat.hpp | 70 typedef rxu::decay_t<Coordination> coordination_type; typedef
72 typedef typename coordination_type::coordinator_type coordinator_type;
80 values(source_operator_type o, coordination_type sf) in values()
86 coordination_type coordination;
90 concat(const source_type& o, coordination_type sf) in concat()
|
| D | rx-buffer_time_count.hpp | 53 typedef rxu::decay_t<Coordination> coordination_type; typedef
54 typedef typename coordination_type::coordinator_type coordinator_type;
59 buffer_with_time_or_count_values(duration_type p, int n, coordination_type c) in buffer_with_time_or_count_values()
67 coordination_type coordination;
71 buffer_with_time_or_count(duration_type period, int count, coordination_type coordination) in buffer_with_time_or_count()
|
| D | rx-observe_on.hpp | 49 typedef rxu::decay_t<Coordination> coordination_type; typedef
50 typedef typename coordination_type::coordinator_type coordinator_type;
52 coordination_type coordination;
54 observe_on(coordination_type cn) in observe_on()
205 …iber<value_type, observer<value_type, this_type>> make(dest_type d, coordination_type cn, composit… in make()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-replaysubject.hpp | 22 typedef rxu::decay_t<Coordination> coordination_type; typedef
23 typedef typename coordination_type::coordinator_type coordinator_type;
36 typedef typename traits::coordination_type coordination_type; typedef in rxcpp::subjects::detail::replay_observer
48 mutable coordination_type coordination;
63 …explicit replay_observer_state(count_type _count, period_type _period, coordination_type _coordina… in replay_observer_state()
98 …replay_observer(count_type count, period_type period, coordination_type coordination, composite_su… in replay_observer()
|