| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-replaysubject.hpp | 23 typedef typename coordination_type::coordinator_type coordinator_type; typedef
37 typedef typename traits::coordinator_type coordinator_type; typedef in rxcpp::subjects::detail::replay_observer
49 mutable coordinator_type coordinator;
63 …_type _count, period_type _period, coordination_type _coordination, coordinator_type _coordinator,… in replay_observer_state()
114 coordinator_type& get_coordinator() const { in get_coordinator()
|
| D | rx-synchronize.hpp | 23 typedef typename coordination_type::coordinator_type coordinator_type; typedef in rxcpp::subjects::detail::synchronize_observer
24 typedef typename coordinator_type::template get<subscriber<T>>::type output_type;
47 coordinator_type coordinator;
96 … synchronize_observer_state(coordinator_type coor, composite_subscription cs, output_type scbr) in synchronize_observer_state()
238 typedef coordinator<input_type> coordinator_type; typedef in rxcpp::synchronize_in_one_worker
244 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator()
246 return coordinator_type(input_type(std::move(w))); in create_coordinator()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-observe_on.hpp | 50 typedef typename coordination_type::coordinator_type coordinator_type; typedef
88 coordinator_type coordinator;
91 observe_on_state(dest_type d, coordinator_type coor, composite_subscription cs) in observe_on_state()
181 observe_on_observer(dest_type d, coordinator_type coor, composite_subscription cs) in observe_on_observer()
307 typedef coordinator<input_type> coordinator_type; typedef in rxcpp::observe_on_one_worker
313 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator()
315 return coordinator_type(input_type(std::move(w))); in create_coordinator()
|
| D | rx-switch_on_next.hpp | 59 typedef typename coordination_type::coordinator_type coordinator_type; typedef
88 switch_state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe()
100 coordinator_type coordinator; in on_subscribe()
|
| D | rx-sample_time.hpp | 48 typedef typename coordination_type::coordinator_type coordinator_type; typedef
78 …scriber_value(composite_subscription cs, dest_type d, sample_with_time_value v, coordinator_type c) in sample_with_time_subscriber_value()
88 coordinator_type coordinator;
94 …time_observer(composite_subscription cs, dest_type d, sample_with_time_value v, coordinator_type c) in sample_with_time_observer()
|
| D | rx-delay.hpp | 48 typedef typename coordination_type::coordinator_type coordinator_type; typedef
78 …delay_subscriber_values(composite_subscription cs, dest_type d, delay_values v, coordinator_type c) in delay_subscriber_values()
89 coordinator_type coordinator;
95 delay_observer(composite_subscription cs, dest_type d, delay_values v, coordinator_type c) in delay_observer()
|
| D | rx-buffer_time_count.hpp | 54 typedef typename coordination_type::coordinator_type coordinator_type; typedef
86 …ues(composite_subscription cs, dest_type d, buffer_with_time_or_count_values v, coordinator_type c) in buffer_with_time_or_count_subscriber_values()
97 coordinator_type coordinator;
105 …ver(composite_subscription cs, dest_type d, buffer_with_time_or_count_values v, coordinator_type c) in buffer_with_time_or_count_observer()
|
| D | rx-timeout.hpp | 56 typedef typename coordination_type::coordinator_type coordinator_type; typedef
87 …out_subscriber_values(composite_subscription cs, dest_type d, timeout_values v, coordinator_type c) in timeout_subscriber_values()
99 coordinator_type coordinator;
106 … timeout_observer(composite_subscription cs, dest_type d, timeout_values v, coordinator_type c) in timeout_observer()
|
| D | rx-window_time_count.hpp | 54 typedef typename coordination_type::coordinator_type coordinator_type; typedef
86 …ues(composite_subscription cs, dest_type d, window_with_time_or_count_values v, coordinator_type c) in window_with_time_or_count_subscriber_values()
98 coordinator_type coordinator;
107 …ver(composite_subscription cs, dest_type d, window_with_time_or_count_values v, coordinator_type c) in window_with_time_or_count_observer()
|
| D | rx-debounce.hpp | 48 typedef typename coordination_type::coordinator_type coordinator_type; typedef
79 …ce_subscriber_values(composite_subscription cs, dest_type d, debounce_values v, coordinator_type c) in debounce_subscriber_values()
91 coordinator_type coordinator;
99 … debounce_observer(composite_subscription cs, dest_type d, debounce_values v, coordinator_type c) in debounce_observer()
|
| D | rx-window_toggle.hpp | 56 using coordinator_type = typename coordination_type::coordinator_type; typedef
92 …bscriber_values(composite_subscription cs, dest_type d, window_toggle_values v, coordinator_type c) in window_toggle_subscriber_values()
102 coordinator_type coordinator;
108 …toggle_observer(composite_subscription cs, dest_type d, window_toggle_values v, coordinator_type c) in window_toggle_observer()
|
| D | rx-merge.hpp | 80 typedef typename coordination_type::coordinator_type coordinator_type; typedef
109 merge_state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe()
121 coordinator_type coordinator; in on_subscribe()
|
| D | rx-take_until.hpp | 64 typedef typename coordination_type::coordinator_type coordinator_type; typedef
103 take_until_state_type(const values& i, coordinator_type coor, const output_type& oarg) in on_subscribe()
115 coordinator_type coordinator; in on_subscribe()
|
| D | rx-merge_delay_error.hpp | 73 typedef typename coordination_type::coordinator_type coordinator_type; typedef
102 merge_state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe()
115 coordinator_type coordinator; in on_subscribe()
|
| D | rx-skip_until.hpp | 54 typedef typename coordination_type::coordinator_type coordinator_type; typedef
93 state_type(const values& i, coordinator_type coor, const output_type& oarg) in on_subscribe()
105 coordinator_type coordinator; in on_subscribe()
|
| D | rx-amb.hpp | 76 typedef typename coordination_type::coordinator_type coordinator_type; typedef
105 amb_state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe()
115 coordinator_type coordinator; in on_subscribe()
|
| D | rx-concat.hpp | 72 typedef typename coordination_type::coordinator_type coordinator_type; typedef
105 concat_state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe()
173 coordinator_type coordinator; in on_subscribe()
|
| D | rx-buffer_time.hpp | 72 typedef typename coordination_type::coordinator_type coordinator_type; typedef
104 …riber_values(composite_subscription cs, dest_type d, buffer_with_time_values v, coordinator_type c) in buffer_with_time_subscriber_values()
115 coordinator_type coordinator;
122 …ime_observer(composite_subscription cs, dest_type d, buffer_with_time_values v, coordinator_type c) in buffer_with_time_observer()
|
| D | rx-window_time.hpp | 64 typedef typename coordination_type::coordinator_type coordinator_type; typedef
96 …riber_values(composite_subscription cs, dest_type d, window_with_time_values v, coordinator_type c) in window_with_time_subscriber_values()
107 coordinator_type coordinator;
114 …ime_observer(composite_subscription cs, dest_type d, window_with_time_values v, coordinator_type c) in window_with_time_observer()
|
| D | rx-combine_latest.hpp | 114 typedef typename coordination_type::coordinator_type coordinator_type; typedef
210 combine_latest_state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe()
224 coordinator_type coordinator; in on_subscribe()
|
| D | rx-with_latest_from.hpp | 114 typedef typename coordination_type::coordinator_type coordinator_type; typedef
210 with_latest_from_state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe()
224 coordinator_type coordinator; in on_subscribe()
|
| D | rx-sequence_equal.hpp | 54 typedef typename coordination_type::coordinator_type coordinator_type; typedef
87 state_type(const values& vals, coordinator_type coor, const output_type& o) in on_subscribe()
100 coordinator_type coordinator; in on_subscribe()
|
| D | rx-zip.hpp | 148 typedef typename coordination_type::coordinator_type coordinator_type; typedef
242 zip_state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe()
256 coordinator_type coordinator; in on_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-coordination.hpp | 158 typedef coordinator<input_type> coordinator_type; typedef in rxcpp::identity_one_worker
164 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator()
166 return coordinator_type(input_type(std::move(w))); in create_coordinator()
287 typedef coordinator<input_type> coordinator_type; typedef in rxcpp::serialize_one_worker
293 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator()
296 return coordinator_type(input_type(std::move(w), std::move(lock))); in create_coordinator()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-timer.hpp | 50 typedef typename coordination_type::coordinator_type coordinator_type; typedef
|