Searched refs:subscribers (Results 1 – 7 of 7) sorted by relevance
108 Set<IBinder> subscribers = in addSubscription() local110 if (!subscribers.add(addSubscriber(subscriber))) { in addSubscription()127 Set<IBinder> subscribers = in removeSubscription() local129 if (!subscribers.remove(subscriber.asBinder())) { in removeSubscription()134 if (subscribers.isEmpty()) { in removeSubscription()152 Set<IBinder> subscribers = in addSubscription() local155 if (!subscribers.add(addSubscriber(subscriber))) { in addSubscription()178 Set<IBinder> subscribers = in removeSubscription() local180 if (!subscribers.remove(subscriber.asBinder())) { in removeSubscription()186 if (subscribers.isEmpty()) { in removeSubscription()[all …]
322 Set<IVmsSubscriberClient> subscribers = in onMessageReceived() local325 for (IVmsSubscriberClient subscriber : subscribers) { in onMessageReceived()340 Set<IVmsSubscriberClient> subscribers; in onLayersAvailabilityChange() local341 subscribers = new HashSet<>(mSubscribersManager.getListeners()); in onLayersAvailabilityChange()343 for (IVmsSubscriberClient subscriber : subscribers) { in onLayersAvailabilityChange()
187 List<IVehicleCallback> subscribers = mSubscribers.get(opt.propId); in subscribe() local188 if (subscribers == null) { in subscribe()189 subscribers = new ArrayList<>(); in subscribe()190 mSubscribers.put(opt.propId, subscribers); in subscribe()193 for (IVehicleCallback s : subscribers) { in subscribe()196 subscribers.remove(callback); in subscribe()201 subscribers.add(callback); in subscribe()214 List<IVehicleCallback> subscribers = mSubscribers.get(propId); in unsubscribe() local215 if (subscribers != null) { in unsubscribe()216 subscribers.remove(callback); in unsubscribe()[all …]
874 private void assertSubscribers(IVmsSubscriberClient... subscribers) { in assertSubscribers() argument876 assertSubscribers(layer, subscribers); in assertSubscribers()880 private void assertSubscribers(VmsLayer layer, IVmsSubscriberClient... subscribers) { in assertSubscribers() argument882 assertSubscribers(layer, publisherId, subscribers); in assertSubscribers()887 IVmsSubscriberClient... subscribers) { in assertSubscribers() argument889 new HashSet<>(Arrays.asList(subscribers)), in assertSubscribers()