| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-trace.hpp | 60 template<class Observable, class Subscriber>
61 inline void subscribe_enter(const Observable& , const Subscriber& ) {} in subscribe_enter()
68 template<class OperatorSource, class OperatorChain, class Subscriber, class SubscriberLifted>
69 …inline void lift_enter(const OperatorSource&, const OperatorChain&, const Subscriber&, const Subsc… in lift_enter()
88 template<class Subscriber>
89 inline void create_subscriber(const Subscriber&) {} in create_subscriber()
91 template<class Subscriber, class T>
92 inline void on_next_enter(const Subscriber&, const T&) {} in on_next_enter()
93 template<class Subscriber>
94 inline void on_next_return(const Subscriber&) {} in on_next_return()
[all …]
|
| D | rx-coordination.hpp | 59 template<class Subscriber>
62 typedef decltype((*(input_type*)nullptr).out((*(Subscriber*)nullptr))) type;
99 template<class Subscriber>
100 auto out(Subscriber s) const in out()
101 -> typename get_subscriber<Subscriber>::type { in out()
103 static_assert(is_subscriber<Subscriber>::value, "can only synchronize subscribers"); in out()
142 template<class Subscriber>
143 auto out(Subscriber s) const in out()
144 -> Subscriber { in out()
239 template<class Subscriber>
[all …]
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | SubscriberTest.java | 48 Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod")); in testCreate()
49 assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class); in testCreate()
52 Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); in testCreate()
53 assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class); in testCreate()
58 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_basicMethodCall()
70 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_exceptionWrapping()
82 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_errorPassthrough()
96 Subscriber.create(bus, "foo", charAt), Subscriber.create(bus, "foo", charAt)) in testEquals()
97 .addEqualityGroup(Subscriber.create(bus, "bar", charAt)) in testEquals()
98 .addEqualityGroup(Subscriber.create(bus, "foo", concat)) in testEquals()
|
| /external/guava/android/guava-tests/test/com/google/common/eventbus/ |
| D | SubscriberTest.java | 48 Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod")); in testCreate()
49 assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class); in testCreate()
52 Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); in testCreate()
53 assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class); in testCreate()
58 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_basicMethodCall()
70 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_exceptionWrapping()
82 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_errorPassthrough()
96 Subscriber.create(bus, "foo", charAt), Subscriber.create(bus, "foo", charAt)) in testEquals()
97 .addEqualityGroup(Subscriber.create(bus, "bar", charAt)) in testEquals()
98 .addEqualityGroup(Subscriber.create(bus, "foo", concat)) in testEquals()
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | SubscriberRegistry.java | 64 private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers =
76 Multimap<Class<?>, Subscriber> listenerMethods = findAllSubscribers(listener); in register()
78 for (Entry<Class<?>, Collection<Subscriber>> entry : listenerMethods.asMap().entrySet()) { in register()
80 Collection<Subscriber> eventMethodsInListener = entry.getValue(); in register()
82 CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType); in register()
85 CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<>(); in register()
96 Multimap<Class<?>, Subscriber> listenerMethods = findAllSubscribers(listener); in unregister()
98 for (Entry<Class<?>, Collection<Subscriber>> entry : listenerMethods.asMap().entrySet()) { in unregister()
100 Collection<Subscriber> listenerMethodsForType = entry.getValue(); in unregister()
102 CopyOnWriteArraySet<Subscriber> currentSubscribers = subscribers.get(eventType); in unregister()
[all …]
|
| D | Subscriber.java | 35 class Subscriber { class
38 static Subscriber create(EventBus bus, Object listener, Method method) { in create()
40 ? new Subscriber(bus, listener, method) in create()
56 private Subscriber(EventBus bus, Object target, Method method) { in Subscriber() method in Subscriber
112 if (obj instanceof Subscriber) { in equals()
113 Subscriber that = (Subscriber) obj; in equals()
135 static final class SynchronizedSubscriber extends Subscriber {
|
| D | Dispatcher.java | 70 abstract void dispatch(Object event, Iterator<Subscriber> subscribers); in dispatch()
96 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
120 private final Iterator<Subscriber> subscribers;
122 private Event(Object event, Iterator<Subscriber> subscribers) { in Event()
155 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
169 private final Subscriber subscriber;
171 private EventWithSubscriber(Object event, Subscriber subscriber) { in EventWithSubscriber()
183 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-retry-repeat-common.hpp | 17 template <class Values, class Subscriber, class EventHandlers, class T>
18 …struct state_type : public std::enable_shared_from_this<state_type<Values, Subscriber, EventHandle…
21 typedef Subscriber output_type;
93 template<class Subscriber>
94 void on_subscribe(const Subscriber& s) const { in on_subscribe()
95 typedef state_type<values, Subscriber, EventHandlers, T> state_t; in on_subscribe()
136 template<class Subscriber>
137 void on_subscribe(const Subscriber& s) const { in on_subscribe()
138 typedef state_type<values, Subscriber, EventHandlers, T> state_t; in on_subscribe()
|
| D | rx-ignore_elements.hpp | 41 template<class Subscriber>
44 typedef ignore_elements_observer<Subscriber> this_type;
46 typedef rxu::decay_t<Subscriber> dest_type;
72 template<class Subscriber>
73 auto operator()(Subscriber dest) const in operator ()()
74 -> decltype(ignore_elements_observer<Subscriber>::make(std::move(dest))) { in operator ()()
75 return ignore_elements_observer<Subscriber>::make(std::move(dest)); in operator ()()
|
| D | rx-distinct.hpp | 44 template<class Subscriber>
47 typedef distinct_observer<Subscriber> this_type;
49 typedef rxu::decay_t<Subscriber> dest_type;
76 template<class Subscriber>
77 auto operator()(Subscriber dest) const in operator ()()
78 -> decltype(distinct_observer<Subscriber>::make(std::move(dest))) { in operator ()()
79 return distinct_observer<Subscriber>::make(std::move(dest)); in operator ()()
|
| D | rx-finally.hpp | 57 template<class Subscriber>
60 typedef finally_observer<Subscriber> this_type;
62 typedef rxu::decay_t<Subscriber> dest_type;
92 template<class Subscriber>
93 auto operator()(Subscriber dest) const in operator ()()
94 -> decltype(finally_observer<Subscriber>::make(std::move(dest), last_call)) { in operator ()()
95 return finally_observer<Subscriber>::make(std::move(dest), last_call); in operator ()()
|
| D | rx-take_while.hpp | 54 template<class Subscriber>
57 typedef take_while_observer<Subscriber> this_type;
59 typedef rxu::decay_t<Subscriber> dest_type;
88 template<class Subscriber>
89 auto operator()(Subscriber dest) const in operator ()()
90 -> decltype(take_while_observer<Subscriber>::make(std::move(dest), test)) { in operator ()()
91 return take_while_observer<Subscriber>::make(std::move(dest), test); in operator ()()
|
| D | rx-element_at.hpp | 58 template<class Subscriber>
61 typedef element_at_observer<Subscriber> this_type;
63 typedef rxu::decay_t<Subscriber> dest_type;
94 template<class Subscriber>
95 auto operator()(Subscriber dest) const in operator ()()
96 -> decltype(element_at_observer<Subscriber>::make(std::move(dest), initial)) { in operator ()()
97 return element_at_observer<Subscriber>::make(std::move(dest), initial); in operator ()()
|
| D | rx-skip_while.hpp | 54 template<class Subscriber>
57 typedef skip_while_observer<Subscriber> this_type;
59 typedef rxu::decay_t<Subscriber> dest_type;
90 template<class Subscriber>
91 auto operator()(Subscriber dest) const in operator ()()
92 -> decltype(skip_while_observer<Subscriber>::make(std::move(dest), test)) { in operator ()()
93 return skip_while_observer<Subscriber>::make(std::move(dest), test); in operator ()()
|
| D | rx-pairwise.hpp | 47 template<class Subscriber>
50 typedef pairwise_observer<Subscriber> this_type;
52 typedef rxu::decay_t<Subscriber> dest_type;
83 template<class Subscriber>
84 auto operator()(Subscriber dest) const in operator ()()
85 -> decltype(pairwise_observer<Subscriber>::make(std::move(dest))) { in operator ()()
86 return pairwise_observer<Subscriber>::make(std::move(dest)); in operator ()()
|
| D | rx-filter.hpp | 53 template<class Subscriber>
56 typedef filter_observer<Subscriber> this_type;
58 typedef rxu::decay_t<Subscriber> dest_type;
94 template<class Subscriber>
95 auto operator()(Subscriber dest) const in operator ()()
96 -> decltype(filter_observer<Subscriber>::make(std::move(dest), test)) { in operator ()()
97 return filter_observer<Subscriber>::make(std::move(dest), test); in operator ()()
|
| D | rx-ref_count.hpp | 62 template <typename Subscriber>
63 void subscribe(Subscriber&& o) { in subscribe()
64 subscribable.subscribe(std::forward<Subscriber>(o)); in subscribe()
76 template <typename Subscriber>
77 void subscribe(Subscriber&& o) { in subscribe()
78 connectable.subscribe(std::forward<Subscriber>(o)); in subscribe()
146 template<class Subscriber>
147 void on_subscribe(Subscriber&& o) const { in on_subscribe()
160 keepAlive->subscribe(std::forward<Subscriber>(o)); in on_subscribe()
|
| D | rx-distinct_until_changed.hpp | 54 template<class Subscriber>
57 typedef distinct_until_changed_observer<Subscriber> this_type;
59 typedef rxu::decay_t<Subscriber> dest_type;
89 template<class Subscriber>
90 auto operator()(Subscriber dest) const in operator ()()
91 -> decltype(distinct_until_changed_observer<Subscriber>::make(std::move(dest), pred)) { in operator ()()
92 return distinct_until_changed_observer<Subscriber>::make(std::move(dest), pred); in operator ()()
|
| D | rx-time_interval.hpp | 63 template<class Subscriber>
66 typedef time_interval_observer<Subscriber> this_type;
68 typedef rxu::decay_t<Subscriber> dest_type;
99 template<class Subscriber>
100 auto operator()(Subscriber dest) const in operator ()()
101 -> decltype(time_interval_observer<Subscriber>::make(std::move(dest), initial)) { in operator ()()
102 return time_interval_observer<Subscriber>::make(std::move(dest), initial); in operator ()()
|
| D | rx-on_error_resume_next.hpp | 55 template<class Subscriber>
58 typedef on_error_resume_next_observer<Subscriber> this_type;
62 typedef rxu::decay_t<Subscriber> dest_type;
98 template<class Subscriber>
99 auto operator()(Subscriber dest) const in operator ()()
100 -> decltype(on_error_resume_next_observer<Subscriber>::make(std::move(dest), selector)) { in operator ()()
101 return on_error_resume_next_observer<Subscriber>::make(std::move(dest), selector); in operator ()()
|
| D | rx-timestamp.hpp | 62 template<class Subscriber>
65 typedef timestamp_observer<Subscriber> this_type;
67 typedef rxu::decay_t<Subscriber> dest_type;
93 template<class Subscriber>
94 auto operator()(Subscriber dest) const in operator ()()
95 -> decltype(timestamp_observer<Subscriber>::make(std::move(dest), initial)) { in operator ()()
96 return timestamp_observer<Subscriber>::make(std::move(dest), initial); in operator ()()
|
| /external/openscreen/platform/impl/ |
| D | socket_handle_waiter.h | 34 class Subscriber {
36 virtual ~Subscriber() = default;
49 void Subscribe(Subscriber* subscriber, SocketHandleRef handle);
53 void Unsubscribe(Subscriber* subscriber, SocketHandleRef handle);
57 void UnsubscribeAll(Subscriber* subscriber);
61 void OnHandleDeletion(Subscriber* subscriber,
86 Subscriber* subscriber = nullptr;
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 70 abstract void dispatch(Object event, Iterator<Subscriber> subscribers); in dispatch()
96 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
120 private final Iterator<Subscriber> subscribers;
122 private Event(Object event, Iterator<Subscriber> subscribers) { in Event()
155 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
169 private final Subscriber subscriber;
171 private EventWithSubscriber(Object event, Subscriber subscriber) { in EventWithSubscriber()
183 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
|
| D | Subscriber.java | 35 class Subscriber { class
38 static Subscriber create(EventBus bus, Object listener, Method method) { in create()
40 ? new Subscriber(bus, listener, method) in create()
56 private Subscriber(EventBus bus, Object target, Method method) { in Subscriber() method in Subscriber
112 if (obj instanceof Subscriber) { in equals()
113 Subscriber that = (Subscriber) obj; in equals()
135 static final class SynchronizedSubscriber extends Subscriber {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | ConflatedBroadcastChannel.kt | 57 @JvmField val subscribers: Array<Subscriber<E>>? in <lambda>()
101 val subscriber = Subscriber(this) in <lambda>()
121 private fun closeSubscriber(subscriber: Subscriber<E>) { in <lambda>()
135 …private fun addSubscriber(list: Array<Subscriber<E>>?, subscriber: Subscriber<E>): Array<Subscribe… in <lambda>()
141 …private fun removeSubscriber(list: Array<Subscriber<E>>, subscriber: Subscriber<E>): Array<Subscri… in <lambda>()
146 val update = arrayOfNulls<Subscriber<E>>(n - 1) in <lambda>()
156 return update as Array<Subscriber<E>> in <lambda>()
283 private class Subscriber<E>( in <lambda>() class in kotlinx.coroutines.channels.ConflatedBroadcastChannel
|