Searched defs:subscribers (Results 1 – 9 of 9) sorted by relevance
| /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/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/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 | BroadcastChannel.kt | 157 private var subscribers: List<BufferedChannel<E>> = emptyList() variable in kotlinx.coroutines.channels.BroadcastChannelImpl
|
| /external/libbpf/.github/actions/build-selftests/ |
| D | vmlinux.h | 4131 atomic_t subscribers; member
|