| /aosp_15_r20/external/guava/android/guava/src/com/google/common/eventbus/ |
| H A 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()
|
| H A D | EventBus.java | 159 private final SubscriberRegistry subscribers = new SubscriberRegistry(this); field in EventBus
|
| H A D | SubscriberRegistry.java | 65 private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = field in SubscriberRegistry
|
| /aosp_15_r20/external/guava/guava/src/com/google/common/eventbus/ |
| H A 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()
|
| H A D | EventBus.java | 162 private final SubscriberRegistry subscribers = new SubscriberRegistry(this); field in EventBus
|
| H A D | SubscriberRegistry.java | 65 private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = field in SubscriberRegistry
|
| /aosp_15_r20/packages/services/Car/tests/CarServiceTest/dep/src/com/android/car/hal/test/ |
| D | HidlMockedVehicleHal.java | 230 List<IVehicleCallback> subscribers = mSubscribers.get(opt.propId); in subscribe() local
260 List<IVehicleCallback> subscribers = mSubscribers.get(propId); in unsubscribe() local
|
| D | AidlMockedVehicleHal.java | 342 List<IVehicleCallback> subscribers = mSubscribers.get(opt.propId); in subscribe() local
374 List<IVehicleCallback> subscribers = mSubscribers.get(propId); in unsubscribe() local
|
| /aosp_15_r20/packages/services/Car/tests/CarTelemetryApp/src/com/android/car/cartelemetryapp/ |
| D | ConfigParser.java | 168 List<Subscriber> subscribers = null; in parseMetricsConfig() local
192 List<Subscriber> subscribers = new ArrayList<>(); in parseSubscribers() local
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| H A D | SharingStressTest.kt | 95 val subscribers = ArrayList<SubJob>() in <lambda>() constant
|
| /aosp_15_r20/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/ |
| H A D | XdsTestControlPlaneService.java | 79 private ImmutableMap<String, Map<StreamObserver<DiscoveryResponse>, Set<String>>> subscribers field in XdsTestControlPlaneService
|
| /aosp_15_r20/device/google/cuttlefish/host/commands/kernel_log_monitor/ |
| D | kernel_log_server.cc | 72 std::vector<EventCallback>* subscribers) { in ProcessSubscriptions()
|
| /aosp_15_r20/packages/services/Car/service/src/com/android/car/telemetry/publisher/ |
| D | CarTelemetrydPublisher.java | 162 ArrayList<DataSubscriber> subscribers = mCarIdSubscriberLookUp.valueAt(i); in getMetricsConfigs() local
|
| D | VehiclePropertyPublisher.java | 340 public final ArraySet<DataSubscriber> subscribers = new ArraySet<>(); field in VehiclePropertyPublisher.PropertyData
|
| D | ConnectivityPublisher.java | 216 ArrayList<DataSubscriber> subscribers = mSubscribers.get(queryParam); in processPreviousSession() local
|
| /aosp_15_r20/packages/services/Car/car-lib/src/android/car/telemetry/ |
| D | telemetry.proto | 53 repeated Subscriber subscribers = 4; field
|
| /aosp_15_r20/frameworks/native/libs/bufferstreams/rust/src/ |
| H A D | lib.rs | 20 pub mod subscribers; module
|
| /aosp_15_r20/tools/netsim/rust/daemon/src/ |
| H A D | events.rs | 110 subscribers: Vec<Sender<Event>>, field
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| H A D | BroadcastChannel.kt | 154 private var subscribers: List<BufferedChannel<E>> = emptyList() variable in kotlinx.coroutines.channels.BroadcastChannelImpl
|
| /aosp_15_r20/packages/services/Car/service/src/com/android/car/vms/ |
| D | VmsBrokerService.java | 251 ArrayList<VmsClientInfo> subscribers = new ArrayList<>(); in deliverToSubscribers() local
|
| /aosp_15_r20/prebuilts/tools/common/m2/repository/io/reactivex/rxjava2/rxjava/2.2.9/ |
| HD | rxjava-2.2.9.jar | ... .reactivex.Single)
}
io/reactivex/subscribers/
io/reactivex/subscribers/SafeSubscriber.class ... |
| /aosp_15_r20/external/aws-sdk-java-v2/services/securitylake/src/main/resources/codegen-resources/ |
| H A D | service-2.json | 1756 "subscribers":{ object
|
| /aosp_15_r20/external/guice/lib/ |
| HD | guava-19.0.jar | META-INF/MANIFEST.MF
META-INF/
META-INF/maven/
META- ... |
| /aosp_15_r20/external/javaparser/javaparser-symbol-solver-testing/src/test/test_sourcecode/javasymbolsolver_0_6_0/lib/ |
| HD | guava-21.0.jar | META-INF/MANIFEST.MF
META-INF/
META-INF/maven/
META- ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/tools/common/m2/dialer-common-m2-host-deps/linux_glibc_common/local-combined/ |
| D | dialer-common-m2-host-deps.jar | META-INF/
META-INF/MANIFEST.MF
META-INF/LICENSE.txt
META ... |