/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...] |
AnnotatedSubscriberFinder.java | 40 * A {@link SubscriberFindingStrategy} for collecting all event subscriber methods that are marked 75 EventSubscriber subscriber = makeSubscriber(listener, method); local 76 methodsInListener.put(eventType, subscriber); 124 + " arguments. Event subscriber methods must require a single argument."); 143 * @param listener object bearing the event subscriber method. 144 * @param method the event subscriber method to wrap in an EventSubscriber. 162 * @param method subscriber method to check. 163 * @return {@code true} if {@code subscriber} is marked as thread-safe,
|
/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...] |
/tools/test/connectivity/acts/tests/google/wifi/ |
WifiNanManagerTest.py | 37 self.subscriber = self.android_devices[1] 55 assert wutils.wifi_toggle_state(self.subscriber, True) 59 assert wutils.wifi_toggle_state(self.subscriber, False) 89 other as Subscriber (S) 103 self.subscriber.droid.wifiNanEnable(self.config_request2) 117 event = self.subscriber.ed.pop_event(ON_IDENTITY_CHANGED, 30) 120 asserts.fail('Timed out while waiting for %s on Subscriber' % 126 self.subscriber.droid.wifiNanSubscribe(self.subscribe_data, 130 event = self.subscriber.ed.pop_event(ON_MATCH, 30) 133 asserts.fail('Timed out while waiting for %s on Subscriber' % ON_MATCH [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...] |
/hardware/qcom/gps/msmcobalt/loc_api/libloc_api_50001/ |
loc_eng_agps.cpp | 45 // data -- an instance of Subscriber 48 delete (Subscriber*)data; 52 // when the state manchine needs to process for particular subscriber 58 Subscriber* s1 = (Subscriber*)fromList; 63 // This is gvien to linked_list_search() to notify subscriber objs 71 Subscriber* s1 = (Subscriber*)fromList; 73 // we notify every subscriber indiscriminatively 74 // each subscriber decides if this notification is interesting 290 Subscriber* subscriber = (Subscriber*) data; local 342 Subscriber* subscriber = (Subscriber*) data; local 429 Subscriber* subscriber = (Subscriber*) data; local 441 Subscriber* subscriber = (Subscriber*) data; local 532 Subscriber* subscriber = (Subscriber*) data; local 839 DSSubscriber *subscriber = NULL; local [all...] |
loc_eng_agps.h | 50 struct Subscriber; 76 // goes to every subscriber 78 // goes to every ACTIVE subscriber 80 // goes to every INACTIVE subscriber 83 // go to a specific subscriber 84 const Subscriber* rcver; 89 // should the subscriber be deleted after the notification 100 inline Notification(const Subscriber* subscriber, 103 rcver(subscriber), groupID(-1), rsrcStatus(status) [all...] |
/frameworks/base/core/java/android/net/ |
INetworkPolicyManager.aidl | 77 void factoryReset(String subscriber);
|
NetworkPolicyManager.java | 235 public void factoryReset(String subscriber) { 237 mService.factoryReset(subscriber);
|
/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...] |