| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| rx-switch_on_next.hpp | 78 template<class Subscriber>
79 void on_subscribe(Subscriber scbr) const {
80 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
82 typedef Subscriber output_type;
|
| rx-buffer_time.hpp | 94 template<class Subscriber>
97 typedef buffer_with_time_observer<Subscriber> this_type;
99 typedef rxu::decay_t<Subscriber> dest_type;
236 static subscriber<T, observer<T, this_type>> make(dest_type d, buffer_with_time_values v) {
244 template<class Subscriber>
245 auto operator()(Subscriber dest) const
246 -> decltype(buffer_with_time_observer<Subscriber>::make(std::move(dest), initial)) {
247 return buffer_with_time_observer<Subscriber>::make(std::move(dest), initial);
|
| rx-window_time.hpp | 86 template<class Subscriber>
89 typedef window_with_time_observer<Subscriber> this_type;
91 typedef rxu::decay_t<Subscriber> dest_type;
232 static subscriber<T, observer_type> make(dest_type d, window_with_time_values v) {
240 template<class Subscriber>
241 auto operator()(Subscriber dest) const
242 -> decltype(window_with_time_observer<Subscriber>::make(std::move(dest), initial)) {
243 return window_with_time_observer<Subscriber>::make(std::move(dest), initial);
|
| rx-window_toggle.hpp | 82 template<class Subscriber>
85 typedef window_toggle_observer<Subscriber> this_type;
87 typedef rxu::decay_t<Subscriber> dest_type;
255 static subscriber<T, observer_type> make(dest_type d, window_toggle_values v) {
263 template<class Subscriber>
264 auto operator()(Subscriber dest) const
265 -> decltype(window_toggle_observer<Subscriber>::make(std::move(dest), initial)) {
266 return window_toggle_observer<Subscriber>::make(std::move(dest), initial);
|
| rx-amb.hpp | 95 template<class Subscriber>
96 void on_subscribe(Subscriber scbr) const {
97 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
99 typedef Subscriber output_type;
|
| rx-concat.hpp | 95 template<class Subscriber>
96 void on_subscribe(Subscriber scbr) const {
97 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
99 typedef Subscriber output_type;
|
| rx-merge.hpp | 99 template<class Subscriber>
100 void on_subscribe(Subscriber scbr) const {
101 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
103 typedef Subscriber output_type;
|
| rx-merge_delay_error.hpp | 92 template<class Subscriber>
93 void on_subscribe(Subscriber scbr) const {
94 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
96 typedef Subscriber output_type;
|
| rx-sequence_equal.hpp | 78 template<class Subscriber>
79 void on_subscribe(Subscriber s) const {
81 typedef Subscriber output_type;
|
| rx-skip_until.hpp | 85 template<class Subscriber>
86 void on_subscribe(Subscriber s) const {
88 typedef Subscriber output_type;
|
| rx-take_until.hpp | 95 template<class Subscriber>
96 void on_subscribe(Subscriber s) const {
98 typedef Subscriber output_type;
|
| rx-combine_latest.hpp | 200 template<class Subscriber>
201 void on_subscribe(Subscriber scbr) const {
202 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
204 typedef Subscriber output_type;
|
| rx-concat_map.hpp | 128 template<class Subscriber>
129 void on_subscribe(Subscriber scbr) const {
130 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
132 typedef Subscriber output_type;
|
| rx-flat_map.hpp | 124 template<class Subscriber>
125 void on_subscribe(Subscriber scbr) const {
126 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
128 typedef Subscriber output_type;
|
| rx-with_latest_from.hpp | 200 template<class Subscriber>
201 void on_subscribe(Subscriber scbr) const {
202 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
204 typedef Subscriber output_type;
|
| rx-zip.hpp | 232 template<class Subscriber>
233 void on_subscribe(Subscriber scbr) const {
234 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
236 typedef Subscriber output_type;
|
| rx-reduce.hpp | 140 template<class Subscriber>
141 void on_subscribe(Subscriber o) const {
146 reduce_state_type(reduce_initial_type i, Subscriber scrbr)
155 Subscriber out;
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| rx-iterate.hpp | 88 template<class Subscriber>
89 void on_subscribe(Subscriber o) const {
90 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber");
92 typedef typename coordinator_type::template get<Subscriber>::type output_type;
|
| rx-error.hpp | 64 template<class Subscriber>
65 void on_subscribe(Subscriber o) const {
|
| /external/guava/guava-tests/test/com/google/common/eventbus/outside/ |
| AnnotatedSubscriberFinderTests.java | 42 private H subscriber; field in class:AnnotatedSubscriberFinderTests.AbstractEventBusTest
45 return subscriber;
50 subscriber = createSubscriber();
52 bus.register(subscriber);
58 subscriber = null;
66 AbstractEventBusTest<BaseSubscriberFinderTest.Subscriber> {
67 static class Subscriber {
76 public void subscriber(Object o) { method in class:AnnotatedSubscriberFinderTests.BaseSubscriberFinderTest.Subscriber
90 Subscriber createSubscriber() {
91 return new Subscriber();
[all...] |
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| rx-synchronize.hpp | 24 typedef typename coordinator_type::template get<subscriber<T>>::type output_type;
145 subscriber<T> get_subscriber() const {
178 subscriber<T> get_subscriber() const {
184 return make_observable_dynamic<T>([=](subscriber<T> o){
222 template<class Subscriber>
223 auto out(Subscriber s) const
224 -> Subscriber {
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| rx-observable.hpp | 20 template<class Subscriber, class T>
29 typedef decltype(check<rxu::decay_t<Subscriber>, T>(0)) detail_result;
42 typedef std::function<void(subscriber<T>)> onsubscribe_type;
54 state->on_subscribe = [so](subscriber<T> o) mutable {
81 void on_subscribe(subscriber<T> o) const {
85 template<class Subscriber>
86 typename std::enable_if<is_subscriber<Subscriber>::value, void>::type
87 on_subscribe(Subscriber o) const {
223 /// `subscribe` will cause this observable to emit values to the provided subscriber.
229 /// callers must provide enough arguments to make a subscriber
519 sc.create_worker(o.get_subscription()).schedule(subscriber); variable
[all...] |
| rx-observer.hpp | 651 template<class F, class Subscriber>
652 auto on_exception(const F& f, const Subscriber& s)
653 -> typename std::enable_if<is_subscriber<Subscriber>::value, typename detail::maybe_from_result<F>::type>::type {
|
| /external/cldr/tools/java/libs/ |
| guava.jar | |
| /external/guice/lib/ |
| guava-19.0.jar | |
