Searched defs:subscribers (Results 1 – 11 of 11) sorted by relevance
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 71 abstract void dispatch(Object event, Iterator<Subscriber> subscribers); in dispatch()
97 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
121 private final Iterator<Subscriber> subscribers; field in Dispatcher.PerThreadQueuedDispatcher.Event
123 private Event(Object event, Iterator<Subscriber> subscribers) { in Event()
156 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
184 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
|
| D | EventBus.java | 159 private final SubscriberRegistry subscribers = new SubscriberRegistry(this); field in EventBus
|
| D | SubscriberRegistry.java | 65 private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = field in SubscriberRegistry
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 71 abstract void dispatch(Object event, Iterator<Subscriber> subscribers); in dispatch()
97 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
121 private final Iterator<Subscriber> subscribers; field in Dispatcher.PerThreadQueuedDispatcher.Event
123 private Event(Object event, Iterator<Subscriber> subscribers) { in Event()
156 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
184 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
|
| D | EventBus.java | 159 private final SubscriberRegistry subscribers = new SubscriberRegistry(this); field in EventBus
|
| D | SubscriberRegistry.java | 65 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 | 69 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
|
| /external/libbpf/.github/actions/build-selftests/ |
| D | vmlinux.h | 4131 atomic_t subscribers; member
|