Searched defs:subscribers (Results 1 – 10 of 10) sorted by relevance
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 72 abstract void dispatch(Object event, Iterator<Subscriber> subscribers); in dispatch()
98 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
123 private final Iterator<Subscriber> subscribers; field in Dispatcher.PerThreadQueuedDispatcher.Event
125 private Event(Object event, Iterator<Subscriber> subscribers) { in Event()
158 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
186 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
|
| D | EventBus.java | 162 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 | 72 abstract void dispatch(Object event, Iterator<Subscriber> subscribers); in dispatch()
98 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
123 private final Iterator<Subscriber> subscribers; field in Dispatcher.PerThreadQueuedDispatcher.Event
125 private Event(Object event, Iterator<Subscriber> subscribers) { in Event()
158 void dispatch(Object event, Iterator<Subscriber> subscribers) { in dispatch()
186 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/grpc-grpc-java/xds/src/test/java/io/grpc/xds/ |
| D | XdsTestControlPlaneService.java | 79 private ImmutableMap<String, Map<StreamObserver<DiscoveryResponse>, Set<String>>> subscribers field in XdsTestControlPlaneService
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | SharingStressTest.kt | 95 val subscribers = ArrayList<SubJob>() in <lambda>() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | BroadcastChannel.kt | 106 private var subscribers: List<BufferedChannel<E>> = emptyList() variable in kotlinx.coroutines.channels.BroadcastChannelImpl
|
| /external/aws-sdk-java-v2/services/securitylake/src/main/resources/codegen-resources/ |
| D | service-2.json | 1756 "subscribers":{ object
|