HomeSort by relevance Sort by last modified time
    Searched refs:subscriber (Results 1 - 25 of 91) sorted by null

1 2 3 4

  /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...]

Completed in 528 milliseconds

1 2 3 4