/packages/services/Car/car-lib/src/android/car/vms/ |
IVmsSubscriberService.aidl | 28 * Adds a subscriber to notifications only. 29 * Should be called when a subscriber registers its callback, and before any subscription to a 33 in IVmsSubscriberClient subscriber) = 0; 36 * Adds a subscriber to a VMS layer. 39 in IVmsSubscriberClient subscriber, 43 * Adds a subscriber to all actively broadcasted layers. 47 void addVmsSubscriberPassive(in IVmsSubscriberClient subscriber) = 2; 50 * Adds a subscriber to a VMS layer from a specific publisher. 53 in IVmsSubscriberClient subscriber, 58 * Removes a subscriber to notifications only [all...] |
/external/guava/guava/src/com/google/common/eventbus/ |
SubscriberExceptionContext.java | 23 * Context for an exception thrown by a subscriber. 30 private final Object subscriber; field in class:SubscriberExceptionContext 35 * subscriber. Useful for broadcasting a a new event based on the error. 36 * @param event The event object that caused the subscriber to throw. 37 * @param subscriber The source subscriber context. 40 SubscriberExceptionContext(EventBus eventBus, Object event, Object subscriber, 44 this.subscriber = checkNotNull(subscriber); 49 * @return The {@link EventBus} that handled the event and the subscriber [all...] |
AsyncEventBus.java | 85 void enqueueEvent(Object event, EventSubscriber subscriber) { 86 eventsToDispatch.offer(new EventWithSubscriber(event, subscriber)); 102 dispatch(eventWithSubscriber.event, eventWithSubscriber.subscriber); 107 * Calls the {@link #executor} to dispatch {@code event} to {@code subscriber}. 110 void dispatch(final Object event, final EventSubscriber subscriber) { 112 checkNotNull(subscriber); 117 AsyncEventBus.super.dispatch(event, subscriber);
|
EventBus.java | 58 * <li>Expose a public method, known as the <i>event subscriber</i>, which accepts 71 * to any subscriber for any type to which the event is <em>assignable.</em> This 80 * <h2>Subscriber Methods</h2> 81 * <p>Event subscriber methods must accept only one argument: the event. 88 * <p>The EventBus guarantees that it will not call a subscriber method from 91 * not present, subscriber methods need not worry about being reentrant, unless 99 * <p>If a subscriber for a supertype of all events (such as Object) is registered, 101 * Accordingly, while DeadEvent extends {@link Object}, a subscriber registered to 143 * Strategy for finding subscriber methods in registered objects. Currently, 187 * @param subscriberExceptionHandler Handler for subscriber exceptions 393 final EventSubscriber subscriber; field in class:EventBus.EventWithSubscriber [all...] |
/packages/services/Car/service/src/com/android/car/ |
VmsSubscriberService.java | 42 * + Offers subscriber/publisher services by implementing IVmsService.Stub. 88 IVmsSubscriberClient subscriber = mSubscriberMap.get(mSubscriberBinder); local 90 // Remove the subscriber subscriptions. 91 if (subscriber != null) { 92 Log.d(TAG, "Removing subscriptions for dead subscriber: " + subscriber); 93 mHal.removeDeadSubscriber(subscriber); 95 Log.d(TAG, "Handling dead binder with no matching subscriber"); 117 * Adds the subscriber and a death recipient associated to it. 119 * @param subscriber to be added [all...] |
VmsRouting.java | 67 * Add a subscriber subscription to data messages from a VMS layer. 69 * @param subscriber a VMS subscriber. 72 public void addSubscription(IVmsSubscriberClient subscriber, VmsLayer layer) { 83 // Add the subscriber to the list. 84 subscribers.add(subscriber); 90 * Add a subscriber subscription to all data messages. 92 * @param subscriber a VMS subscriber. 94 public void addSubscription(IVmsSubscriberClient subscriber) { [all...] |
/device/linaro/bootloader/arm-trusted-firmware/include/lib/el3_runtime/ |
pubsub.h | 58 * the event, and 'subscriber' a local variable of type 'pubsub_cb_t *'. 60 #define for_each_subscriber(event, subscriber) \ 61 for (subscriber = __pubsub_start_sym(event); \ 62 subscriber < __pubsub_end_sym(event); \ 63 subscriber++) 71 pubsub_cb_t *subscriber; \ 72 for_each_subscriber(event, subscriber) { \ 73 (*subscriber)(arg); \ 80 /* Subscriber callback type */
|
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/ |
VmsRoutingTest.java | 54 MockVmsSubscriber subscriber = new MockVmsSubscriber(); local 55 mRouting.addSubscription(subscriber, LAYER_WITH_SUBSCRIPTION_1); 69 // Verify there is only a single subscriber. 77 MockVmsSubscriber subscriber = new MockVmsSubscriber(); local 78 mRouting.addSubscription(subscriber, LAYER_WITH_SUBSCRIPTION_1); 79 mRouting.addSubscription(subscriber, LAYER_WITH_SUBSCRIPTION_2); 81 // Add a HAL subscription to a layer there is already another subscriber for. 96 MockVmsSubscriber subscriber = new MockVmsSubscriber(); local 97 mRouting.addSubscription(subscriber, LAYER_WITH_SUBSCRIPTION_1); 103 mRouting.removeSubscription(subscriber, LAYER_WITH_SUBSCRIPTION_1) 156 MockVmsSubscriber subscriber = new MockVmsSubscriber(); local 194 MockVmsSubscriber subscriber = new MockVmsSubscriber(); local 228 MockVmsSubscriber subscriber = new MockVmsSubscriber(); local 265 MockVmsSubscriber subscriber = new MockVmsSubscriber(); local [all...] |
/hardware/qcom/gps/msm8909w_3100/gnss/ |
Agps.cpp | 77 /* Add subscriber to list 95 * Just add this subscriber to the list, for notifications */ 101 * Notify current subscriber with GRANTED event, 102 * And add it to the subscriber list for further notifications. */ 127 /* If the subscriber wishes to wait for connection close, 136 /* Notify only current subscriber and then delete it from 156 /* If the subscriber wishes to wait for connection close, 165 /* Notify only current subscriber and then delete it from 212 /* Subscriber list should be empty if we are in released state */ 333 AgpsSubscriber* subscriber = *it local 413 AgpsSubscriber* subscriber = *it; local 433 AgpsSubscriber* subscriber = *it; local 448 AgpsSubscriber* subscriber = *it; local 481 AgpsSubscriber* subscriber = *it; local 496 AgpsSubscriber* subscriber = *it; local 513 AgpsSubscriber* subscriber = *it; local 568 AgpsSubscriber* subscriber = getFirstSubscriber(false); local 602 AgpsSubscriber* subscriber = getFirstSubscriber(false); local 809 AgpsSubscriber* subscriber = NULL; local [all...] |
Agps.h | 161 /* SUBSCRIBER 162 * Each Subscriber instance corresponds to one AGPS request, 169 /* Does this subscriber wait for data call close complete, 171 * While waiting for data call close, subscriber will be in 198 * Once a subscriber is notified for ATL open/close status, 202 /* Current subscriber, whose request this State Machine is 238 inline void setCurrentSubscriber(AgpsSubscriber* subscriber) 239 { mCurrentSubscriber = subscriber; } 241 /* Fetch subscriber with specified handle */ 244 /* Fetch first active or inactive subscriber in lis [all...] |
/hardware/qcom/gps/msm8998/gnss/ |
Agps.cpp | 77 /* Add subscriber to list 95 * Just add this subscriber to the list, for notifications */ 101 * Notify current subscriber with GRANTED event, 102 * And add it to the subscriber list for further notifications. */ 127 /* If the subscriber wishes to wait for connection close, 134 /* Notify only current subscriber and then delete it from 154 /* If the subscriber wishes to wait for connection close, 161 /* Notify only current subscriber and then delete it from 325 AgpsSubscriber* subscriber = *it; local 329 subscriber->mIsInactive) | 405 AgpsSubscriber* subscriber = *it; local 425 AgpsSubscriber* subscriber = *it; local 440 AgpsSubscriber* subscriber = *it; local 473 AgpsSubscriber* subscriber = *it; local 488 AgpsSubscriber* subscriber = *it; local 505 AgpsSubscriber* subscriber = *it; local 560 AgpsSubscriber* subscriber = getFirstSubscriber(false); local 594 AgpsSubscriber* subscriber = getFirstSubscriber(false); local 801 AgpsSubscriber* subscriber = NULL; local [all...] |
/external/tensorflow/tensorflow/core/platform/default/gpu/ |
cupti_wrapper.cc | 106 CUpti_SubscriberHandle subscriber, 109 return dynload::cuptiEnableCallback(enable, subscriber, domain, cbid); 113 CUpti_SubscriberHandle subscriber, 115 return dynload::cuptiEnableDomain(enable, subscriber, domain); 118 CUptiResult CuptiWrapper::Subscribe(CUpti_SubscriberHandle* subscriber, 121 return dynload::cuptiSubscribe(subscriber, callback, userdata); 124 CUptiResult CuptiWrapper::Unsubscribe(CUpti_SubscriberHandle subscriber) { 125 return dynload::cuptiUnsubscribe(subscriber);
|
cupti_wrapper.h | 60 CUptiResult EnableCallback(uint32_t enable, CUpti_SubscriberHandle subscriber, 64 CUptiResult EnableDomain(uint32_t enable, CUpti_SubscriberHandle subscriber, 67 CUptiResult Subscribe(CUpti_SubscriberHandle* subscriber, 70 CUptiResult Unsubscribe(CUpti_SubscriberHandle subscriber);
|
/frameworks/base/packages/SystemUI/src/com/android/systemui/recents/events/ |
EventBus.java | 46 * Represents a subscriber, which implements various event bus handler methods. 48 class Subscriber { 53 Subscriber(Object subscriber, long registrationTime) { 54 mSubscriber = new WeakReference<>(subscriber); 74 Subscriber subscriber; field in class:EventHandler 77 EventHandler(Subscriber subscriber, EventHandlerMethod method, int priority) { 78 this.subscriber = subscriber 698 Object subscriber = handler.subscriber.getReference(); local [all...] |
/external/guava/guava-tests/test/com/google/common/eventbus/ |
EventSubscriberTest.java | 53 EventSubscriber subscriber = new EventSubscriber(this, method); local 55 subscriber.handleEvent(FIXTURE_ARGUMENT); 57 assertTrue("Subscriber must call provided method.", methodCalled); 58 assertTrue("Subscriber argument must be *exactly* the provided object.", 64 EventSubscriber subscriber = new EventSubscriber(this, method); local 67 subscriber.handleEvent(new Object()); 77 EventSubscriber subscriber = new EventSubscriber(this, method); local 80 subscriber.handleEvent(new Object());
|
/hardware/qcom/gps/loc_api/libloc_api_50001/ |
loc_eng_agps.cpp | 46 // data -- an instance of Subscriber 49 delete (Subscriber*)data; 53 // when the state manchine needs to process for particular subscriber 59 Subscriber* s1 = (Subscriber*)fromList; 64 // This is gvien to linked_list_search() to notify subscriber objs 72 Subscriber* s1 = (Subscriber*)fromList; 74 // we notify every subscriber indiscriminatively 75 // each subscriber decides if this notification is interesting 291 Subscriber* subscriber = (Subscriber*) data; local 343 Subscriber* subscriber = (Subscriber*) data; local 430 Subscriber* subscriber = (Subscriber*) data; local 442 Subscriber* subscriber = (Subscriber*) data; local 533 Subscriber* subscriber = (Subscriber*) data; local 840 DSSubscriber *subscriber = NULL; local [all...] |
/hardware/qcom/gps/msm8084/loc_api/libloc_api_50001/ |
loc_eng_agps.cpp | 46 // data -- an instance of Subscriber 49 delete (Subscriber*)data; 53 // when the state manchine needs to process for particular subscriber 59 Subscriber* s1 = (Subscriber*)fromList; 64 // This is gvien to linked_list_search() to notify subscriber objs 72 Subscriber* s1 = (Subscriber*)fromList; 74 // we notify every subscriber indiscriminatively 75 // each subscriber decides if this notification is interesting 291 Subscriber* subscriber = (Subscriber*) data; local 343 Subscriber* subscriber = (Subscriber*) data; local 430 Subscriber* subscriber = (Subscriber*) data; local 442 Subscriber* subscriber = (Subscriber*) data; local 533 Subscriber* subscriber = (Subscriber*) data; local 841 DSSubscriber *subscriber = NULL; local [all...] |
/hardware/qcom/gps/msm8909/loc_api/libloc_api_50001/ |
loc_eng_agps.cpp | 46 // data -- an instance of Subscriber 49 delete (Subscriber*)data; 53 // when the state manchine needs to process for particular subscriber 59 Subscriber* s1 = (Subscriber*)fromList; 64 // This is gvien to linked_list_search() to notify subscriber objs 72 Subscriber* s1 = (Subscriber*)fromList; 74 // we notify every subscriber indiscriminatively 75 // each subscriber decides if this notification is interesting 291 Subscriber* subscriber = (Subscriber*) data; local 343 Subscriber* subscriber = (Subscriber*) data; local 430 Subscriber* subscriber = (Subscriber*) data; local 442 Subscriber* subscriber = (Subscriber*) data; local 533 Subscriber* subscriber = (Subscriber*) data; local 840 DSSubscriber *subscriber = NULL; local [all...] |
/hardware/qcom/gps/msm8960/loc_api/libloc_api_50001/ |
loc_eng_agps.cpp | 46 // data -- an instance of Subscriber 49 delete (Subscriber*)data; 53 // when the state manchine needs to process for particular subscriber 59 Subscriber* s1 = (Subscriber*)fromList; 64 // This is gvien to linked_list_search() to notify subscriber objs 72 Subscriber* s1 = (Subscriber*)fromList; 74 // we notify every subscriber indiscriminatively 75 // each subscriber decides if this notification is interesting 291 Subscriber* subscriber = (Subscriber*) data; local 343 Subscriber* subscriber = (Subscriber*) data; local 430 Subscriber* subscriber = (Subscriber*) data; local 442 Subscriber* subscriber = (Subscriber*) data; local 533 Subscriber* subscriber = (Subscriber*) data; local 840 DSSubscriber *subscriber = NULL; local [all...] |
loc_eng_agps.h | 46 class Subscriber; 72 // goes to every subscriber 74 // goes to every ACTIVE subscriber 76 // goes to every INACTIVE subscriber 79 // go to a specific subscriber 80 const Subscriber* rcver; 85 // should the subscriber be deleted after the notification 96 inline Notification(const Subscriber* subscriber, 99 rcver(subscriber), groupID(-1), rsrcStatus(status) [all...] |
/hardware/qcom/gps/msm8994/loc_api/libloc_api_50001/ |
loc_eng_agps.cpp | 46 // data -- an instance of Subscriber 49 delete (Subscriber*)data; 53 // when the state manchine needs to process for particular subscriber 59 Subscriber* s1 = (Subscriber*)fromList; 64 // This is gvien to linked_list_search() to notify subscriber objs 72 Subscriber* s1 = (Subscriber*)fromList; 74 // we notify every subscriber indiscriminatively 75 // each subscriber decides if this notification is interesting 291 Subscriber* subscriber = (Subscriber*) data; local 343 Subscriber* subscriber = (Subscriber*) data; local 430 Subscriber* subscriber = (Subscriber*) data; local 442 Subscriber* subscriber = (Subscriber*) data; local 533 Subscriber* subscriber = (Subscriber*) data; local 840 DSSubscriber *subscriber = NULL; local [all...] |
/hardware/qcom/gps/msm8996/loc_api/libloc_api_50001/ |
loc_eng_agps.cpp | 46 // data -- an instance of Subscriber 49 delete (Subscriber*)data; 53 // when the state manchine needs to process for particular subscriber 59 Subscriber* s1 = (Subscriber*)fromList; 64 // This is gvien to linked_list_search() to notify subscriber objs 72 Subscriber* s1 = (Subscriber*)fromList; 74 // we notify every subscriber indiscriminatively 75 // each subscriber decides if this notification is interesting 291 Subscriber* subscriber = (Subscriber*) data; local 343 Subscriber* subscriber = (Subscriber*) data; local 430 Subscriber* subscriber = (Subscriber*) data; local 442 Subscriber* subscriber = (Subscriber*) data; local 533 Subscriber* subscriber = (Subscriber*) data; local 840 DSSubscriber *subscriber = NULL; local [all...] |
/frameworks/support/room/integration-tests/testapp/src/androidTest/java/androidx/room/integration/testapp/test/ |
RxJava2WithInstantTaskExecutorTest.java | 57 TestSubscriber<User> subscriber = mDatabase.getUserDao().flowableUserById(3).test(); local 58 subscriber.assertValueCount(0); 69 subscriber.assertValueCount(1);
|
RxJava2Test.java | 363 TestSubscriber<Integer> subscriber = new TestSubscriber<>(); local 364 mUserDao.publisherCountUsers().subscribe(subscriber); 366 subscriber.assertSubscribed(); 367 subscriber.request(2); 369 subscriber.assertValue(0); 372 subscriber.assertValues(0, 1); 373 subscriber.cancel(); 374 subscriber.assertNoErrors(); 379 final TestSubscriber<UserAndAllPets> subscriber = new TestSubscriber<>(); local 381 mUserPetDao.flowableUserWithPets(3).subscribe(subscriber); [all...] |
/frameworks/support/lifecycle/reactivestreams/src/main/java/androidx/lifecycle/ |
LiveDataReactiveStreams.java | 24 import org.reactivestreams.Subscriber; 50 * will buffer the latest item and emit it to the subscriber when data is again requested. Any 70 public void subscribe(Subscriber<? super T> subscriber) { 71 subscriber.onSubscribe(new LiveDataSubscription<T>(subscriber, mLifecycle, mLiveData)); 75 final Subscriber<? super T> mSubscriber; 87 LiveDataSubscription(final Subscriber<? super T> subscriber, 89 this.mSubscriber = subscriber; [all...] |