| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscription.hpp | 236 class composite_subscription;
449 inline composite_subscription shared_empty();
459 class composite_subscription class
467 composite_subscription(detail::tag_composite_subscription_empty et) in composite_subscription() function in rxcpp::composite_subscription
475 composite_subscription() in composite_subscription() function in rxcpp::composite_subscription
481 composite_subscription(const composite_subscription& o) in composite_subscription() function in rxcpp::composite_subscription
486 composite_subscription(composite_subscription&& o) in composite_subscription() function in rxcpp::composite_subscription
492 composite_subscription& operator=(composite_subscription o) in operator =()
499 static inline composite_subscription empty() { in empty()
535 inline bool operator<(const composite_subscription& lhs, const composite_subscription& rhs) { in operator <()
[all …]
|
| D | rx-subscriber.hpp | 32 composite_subscription lifetime;
105 typedef typename composite_subscription::weak_subscription weak_subscription;
136 subscriber(trace_id id, composite_subscription cs, U&& o) in subscriber()
159 const composite_subscription& get_subscription() const { in get_subscription()
162 composite_subscription& get_subscription() { in get_subscription()
238 …server_tag, detail::OnNextEmpty<T>>>(trace_id::make_next_id_subscriber(), composite_subscription(), in make_subscriber()
246 … subscriber<T, observer<T, I>>(trace_id::make_next_id_subscriber(), composite_subscription(), o); in make_subscriber()
254 …return subscriber<T, Observer>(trace_id::make_next_id_subscriber(), composite_subscription(), o… in make_subscriber()
264 …iber<T, observer<T, Observer>>(trace_id::make_next_id_subscriber(), composite_subscription(), o); in make_subscriber()
271 …il::stateless_observer_tag, OnNext>>(trace_id::make_next_id_subscriber(), composite_subscription(), in make_subscriber()
[all …]
|
| D | rx-scheduler.hpp | 204 composite_subscription lifetime;
209 typedef composite_subscription::weak_subscription weak_subscription;
214 worker(composite_subscription cs, detail::const_worker_interface_ptr i) in worker()
219 worker(composite_subscription cs, worker o) in worker()
225 inline const composite_subscription& get_subscription() const { in get_subscription()
228 inline composite_subscription& get_subscription() { in get_subscription()
336 composite_subscription lifetime;
365 virtual worker create_worker(composite_subscription cs) const = 0;
412 inline worker create_worker(composite_subscription cs = composite_subscription()) const { in create_worker()
430 composite_subscription lifetime;
[all …]
|
| D | rx-connectable_observable.hpp | 19 static auto check(int) -> decltype((*(CT*)nullptr).on_connect(composite_subscription()));
36 typedef std::function<void(composite_subscription)> onconnect_type;
55 state->on_connect = [so](composite_subscription cs) mutable { in construct()
87 void on_connect(composite_subscription cs) const { in on_connect()
160 composite_subscription connect(composite_subscription cs = composite_subscription()) { in connect()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-replaysubject.hpp | 46 mutable composite_subscription replayLifetime;
63 … coordination_type _coordination, coordinator_type _coordinator, composite_subscription _replayLif… in replay_observer_state()
98 …_type period, coordination_type coordination, composite_subscription replayLifetime, composite_sub… in replay_observer()
138 explicit replay(Coordination cn, composite_subscription cs = composite_subscription()) in replay()
139 : s(count_type(), period_type(), cn, cs, composite_subscription{}) in replay()
143 replay(std::size_t count, Coordination cn, composite_subscription cs = composite_subscription()) in replay()
144 : s(count_type(std::move(count)), period_type(), cn, cs, composite_subscription{}) in replay()
148 …ler::clock_type::duration period, Coordination cn, composite_subscription cs = composite_subscript… in replay()
149 : s(count_type(), period_type(period), cn, cs, composite_subscription{}) in replay()
153 …ler::clock_type::duration period, Coordination cn, composite_subscription cs = composite_subscript… in replay()
[all …]
|
| D | rx-synchronize.hpp | 45 composite_subscription lifetime;
96 … synchronize_observer_state(coordinator_type coor, composite_subscription cs, output_type scbr) in synchronize_observer_state()
134 synchronize_observer(coordination_type cn, composite_subscription dl, composite_subscription il) in synchronize_observer()
169 explicit synchronize(Coordination cn, composite_subscription cs = composite_subscription()) in synchronize()
170 : s(std::move(cn), std::move(cs), composite_subscription()) in synchronize()
244 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator()
|
| D | rx-subject.hpp | 36 explicit state_type(composite_subscription cs) in state_type()
44 composite_subscription lifetime;
83 explicit binder_type(composite_subscription cs) in binder_type()
105 explicit multicast_observer(composite_subscription cs) in multicast_observer()
121 composite_subscription get_subscription() const { in get_subscription()
245 : s(composite_subscription()) in subject()
248 explicit subject(composite_subscription cs) in subject()
257 composite_subscription get_subscription() const { in get_subscription()
|
| D | rx-behavior.hpp | 46 behavior_observer(T f, composite_subscription l) in behavior_observer()
75 explicit behavior(T f, composite_subscription cs = composite_subscription()) in behavior()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-replay.hpp | 109 …ticast(std::forward<Observable>(o), Subject(identity_current_thread(), composite_subscription()))); in member()
120 static Result member(Observable&& o, composite_subscription cs) { in member()
133 …c Result member(Observable&& o, Coordination&& cn, composite_subscription cs = composite_subscript… in member()
146 …static Result member(Observable&& o, Count count, composite_subscription cs = composite_subscripti… in member()
160 …er(Observable&& o, Count count, Coordination&& cn, composite_subscription cs = composite_subscript… in member()
174 …static Result member(Observable&& o, Duration&& d, composite_subscription cs = composite_subscript… in member()
189 …r(Observable&& o, Duration&& d, Coordination&& cn, composite_subscription cs = composite_subscript… in member()
204 … member(Observable&& o, Count count, Duration&& d, composite_subscription cs = composite_subscript… in member()
220 …& o, Count count, Duration&& d, Coordination&& cn, composite_subscription cs = composite_subscript… in member()
|
| D | rx-publish.hpp | 103 return Result(Multicast(std::forward<Observable>(o), Subject(composite_subscription()))); in member()
114 static Result member(Observable&& o, composite_subscription cs) { in member()
126 …static Result member(Observable&& o, T first, composite_subscription cs = composite_subscription()… in member()
150 …c Result member(Observable&& o, Coordination&& cn, composite_subscription cs = composite_subscript… in member()
|
| D | rx-retry-repeat-common.hpp | 24 source_lifetime(composite_subscription::empty()), in state_type()
34 state->source_lifetime = composite_subscription(); in do_subscribe()
55 composite_subscription source_lifetime;
57 composite_subscription::weak_subscription lifetime_token;
|
| D | rx-observe_on.hpp | 86 composite_subscription lifetime;
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()
205 …his_type>> make(dest_type d, coordination_type cn, composite_subscription cs = composite_subscript… in make()
313 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator()
|
| D | rx-concat.hpp | 108 , sourceLifetime(composite_subscription::empty()) in on_subscribe()
109 , collectionLifetime(composite_subscription::empty()) in on_subscribe()
119 collectionLifetime = composite_subscription(); in on_subscribe()
170 composite_subscription sourceLifetime; in on_subscribe()
171 composite_subscription collectionLifetime; in on_subscribe()
182 state->sourceLifetime = composite_subscription(); in on_subscribe()
|
| D | rx-window_toggle.hpp | 92 …window_toggle_subscriber_values(composite_subscription cs, dest_type d, window_toggle_values v, co… in window_toggle_subscriber_values()
100 composite_subscription cs;
108 …window_toggle_observer(composite_subscription cs, dest_type d, window_toggle_values v, coordinator… in window_toggle_observer()
113 composite_subscription innercs; in window_toggle_observer()
145 composite_subscription innercs; in window_toggle_observer()
256 auto cs = composite_subscription(); in make()
|
| D | rx-on_error_resume_next.hpp | 65 composite_subscription lifetime;
68 on_error_resume_next_observer(dest_type d, composite_subscription cs, select_type s) in on_error_resume_next_observer()
93 auto cs = composite_subscription(); in make()
|
| D | rx-concat_map.hpp | 140 , sourceLifetime(composite_subscription::empty()) in on_subscribe()
141 , collectionLifetime(composite_subscription::empty()) in on_subscribe()
158 collectionLifetime = composite_subscription(); in on_subscribe()
209 composite_subscription sourceLifetime; in on_subscribe()
210 composite_subscription collectionLifetime; in on_subscribe()
221 state->sourceLifetime = composite_subscription(); in on_subscribe()
|
| D | rx-switch_if_empty.hpp | 63 composite_subscription lifetime;
67 switch_if_empty_observer(dest_type d, composite_subscription cs, backup_source_type b) in switch_if_empty_observer()
91 auto cs = composite_subscription(); in make()
|
| D | rx-delay.hpp | 78 …delay_subscriber_values(composite_subscription cs, dest_type d, delay_values v, coordinator_type c) in delay_subscriber_values()
87 composite_subscription cs;
95 delay_observer(composite_subscription cs, dest_type d, delay_values v, coordinator_type c) in delay_observer()
163 auto cs = composite_subscription(); in make()
|
| D | rx-amb.hpp | 119 std::vector<composite_subscription> innerSubscriptions; in on_subscribe()
127 composite_subscription outercs; in on_subscribe()
152 composite_subscription innercs; in on_subscribe()
178 auto do_unsubscribe = [](composite_subscription cs) { in on_subscribe()
|
| D | rx-sample_time.hpp | 78 …sample_with_time_subscriber_value(composite_subscription cs, dest_type d, sample_with_time_value v… in sample_with_time_subscriber_value()
86 composite_subscription cs;
94 …sample_with_time_observer(composite_subscription cs, dest_type d, sample_with_time_value v, coordi… in sample_with_time_observer()
182 auto cs = composite_subscription(); in make()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-eventloop.hpp | 31 composite_subscription lifetime;
39 … loop_worker(composite_subscription cs, worker w, std::shared_ptr<const scheduler_interface> alive) in loop_worker()
66 composite_subscription loops_lifetime;
101 virtual worker create_worker(composite_subscription cs) const { in create_worker()
|
| D | rx-newthread.hpp | 42 explicit new_worker_state(composite_subscription cs) in new_worker_state()
47 composite_subscription lifetime;
67 new_worker(composite_subscription cs, thread_factory& tf) in new_worker()
164 virtual worker create_worker(composite_subscription cs) const { in create_worker()
|
| D | rx-runloop.hpp | 34 composite_subscription lifetime;
106 virtual worker create_worker(composite_subscription cs) const { in create_worker()
162 composite_subscription get_subscription() const { in get_subscription()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | publish.cpp | 187 rx::composite_subscription connection;
200 rx::composite_subscription connection;
213 rx::composite_subscription connection;
301 rx::composite_subscription connection;
314 rx::composite_subscription connection;
400 rx::composite_subscription connection;
413 rx::composite_subscription connection;
426 rx::composite_subscription connection;
|
| D | replay.cpp | 49 rx::composite_subscription connection;
62 rx::composite_subscription connection;
75 rx::composite_subscription connection;
162 rx::composite_subscription connection;
175 rx::composite_subscription connection;
250 rx::composite_subscription connection;
380 rx::composite_subscription connection;
499 rx::composite_subscription connection;
618 rx::composite_subscription connection;
|