| /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...] |
| /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,
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
330 AgpsSubscriber* subscriber = *it; local
334 subscriber->mIsInactive) |
410 AgpsSubscriber* subscriber = *it; local
430 AgpsSubscriber* subscriber = *it; local
445 AgpsSubscriber* subscriber = *it; local
478 AgpsSubscriber* subscriber = *it; local
493 AgpsSubscriber* subscriber = *it; local
510 AgpsSubscriber* subscriber = *it; local
565 AgpsSubscriber* subscriber = getFirstSubscriber(false); local
599 AgpsSubscriber* subscriber = getFirstSubscriber(false); local
805 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/sdm845/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
330 AgpsSubscriber* subscriber = *it; local
334 subscriber->mIsInactive) |
410 AgpsSubscriber* subscriber = *it; local
430 AgpsSubscriber* subscriber = *it; local
445 AgpsSubscriber* subscriber = *it; local
478 AgpsSubscriber* subscriber = *it; local
493 AgpsSubscriber* subscriber = *it; local
510 AgpsSubscriber* subscriber = *it; local
565 AgpsSubscriber* subscriber = getFirstSubscriber(false); local
599 AgpsSubscriber* subscriber = getFirstSubscriber(false); local
805 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...] |
| /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());
|
| EventBusTest.java | 130 final Object subscriber = new Object() { local
136 eventBus.register(subscriber);
146 assertEquals("Subscriber should be available.",
147 subscriber, handler.context.getSubscriber());
149 subscriber.getClass().getMethod("throwExceptionOn", String.class),
161 final Object subscriber = new Object() { local
167 eventBus.register(subscriber);
|
| /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...] |
| 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/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...] |
| 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/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...] |
| 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/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...] |
| 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/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...] |
| 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...] |
| /frameworks/support/lifecycle/reactivestreams/src/main/java/android/arch/lifecycle/ |
| LiveDataReactiveStreams.java | 23 import org.reactivestreams.Subscriber;
49 * will buffer the latest item and emit it to the subscriber when data is again requested. Any
63 public void subscribe(final Subscriber<? super T> subscriber) {
72 subscriber.onNext(t);
82 subscriber.onSubscribe(new Subscription() {
142 publisher.subscribe(new Subscriber<T>() {
|
| /frameworks/support/room/integration-tests/testapp/src/androidTest/java/android/arch/persistence/room/integration/testapp/test/ |
| RxJava2Test.java | 259 TestSubscriber<Integer> subscriber = new TestSubscriber<>(); local
260 mUserDao.publisherCountUsers().subscribe(subscriber);
262 subscriber.assertSubscribed();
263 subscriber.request(2);
265 subscriber.assertValue(0);
268 subscriber.assertValues(0, 1);
269 subscriber.cancel();
270 subscriber.assertNoErrors();
|
| /external/guava/guava-tests/test/com/google/common/eventbus/outside/ |
| AnnotatedSubscriberFinderTests.java | 42 private H subscriber; field in class:AnnotatedSubscriberFinderTests.AbstractEventBusTest
45 return subscriber;
50 subscriber = createSubscriber();
52 bus.register(subscriber);
58 subscriber = null;
66 AbstractEventBusTest<BaseSubscriberFinderTest.Subscriber> {
67 static class Subscriber {
76 public void subscriber(Object o) { method in class:AnnotatedSubscriberFinderTests.BaseSubscriberFinderTest.Subscriber
90 Subscriber createSubscriber() {
91 return new Subscriber();
[all...] |
