Searched defs:subscribers (Results 1 – 10 of 10) sorted by relevance
| /external/guava/android/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; field in Dispatcher.PerThreadQueuedDispatcher.Event
122 private Event(Object event, Iterator<Subscriber> subscribers) { in Event()
155 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
183 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
|
| D | EventBus.java | 104 private final SubscriberRegistry subscribers = new SubscriberRegistry(this); field in EventBus
|
| D | SubscriberRegistry.java | 64 private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = field in SubscriberRegistry
|
| /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; field in Dispatcher.PerThreadQueuedDispatcher.Event
122 private Event(Object event, Iterator<Subscriber> subscribers) { in Event()
155 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
183 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
|
| D | EventBus.java | 104 private final SubscriberRegistry subscribers = new SubscriberRegistry(this); field in EventBus
|
| D | SubscriberRegistry.java | 64 private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = field in SubscriberRegistry
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | SharingStressTest.kt | 99 val subscribers = ArrayList<SubJob>() in <lambda>() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | ArrayBroadcastChannel.kt | 63 private val subscribers = subscriberList<Subscriber<E>>() constant in kotlinx.coroutines.channels.ArrayBroadcastChannel
|
| D | ConflatedBroadcastChannel.kt | 57 @JvmField val subscribers: Array<Subscriber<E>>? in <lambda>() constant in kotlinx.coroutines.channels.ConflatedBroadcastChannel.State
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-ref_count.hpp | 117 long subscribers; member
|