| /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,
|
| /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 */
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| create.cpp | 9 [](rxcpp::subscriber<int> s){
25 auto subscriber = rxcpp::make_subscriber<int>( variable
36 [](rxcpp::subscriber<int> s){
43 }).subscribe(subscriber);
50 auto subscriber = rxcpp::make_subscriber<int>( variable
61 [](rxcpp::subscriber<int> s){
70 }).subscribe(subscriber);
77 [](rxcpp::subscriber<int> s){
|
| subscribe.cpp | 6 SCENARIO("subscribe by subscriber"){
7 printf("//! [subscribe by subscriber]\n");
8 auto subscriber = rxcpp::make_subscriber<int>( variable
12 values.subscribe(subscriber);
13 printf("//! [subscribe by subscriber]\n");
18 auto subscriber = rxcpp::make_subscriber<int>( variable
23 values1.subscribe(subscriber.get_observer());
24 values2.subscribe(subscriber.get_observer());
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| rx-subscriber.hpp | 25 class subscriber : public subscriber_base<T> class in namespace:rxcpp
28 static_assert(is_observer<Observer>::value, "subscriber must contain an observer<T, ...>");
29 typedef subscriber<T, Observer> this_type;
103 subscriber();
107 subscriber(const this_type& o) function in class:rxcpp::subscriber
113 subscriber(this_type&& o) function in class:rxcpp::subscriber
121 friend class subscriber;
124 subscriber( function in class:rxcpp::subscriber
125 const subscriber<T, O>& o,
136 subscriber(trace_id id, composite_subscription cs, U&& o function in class:rxcpp::subscriber
[all...] |
| rx-test.hpp | 22 virtual void on_subscribe(subscriber<T>) const =0;
37 void on_subscribe(subscriber<T> o) const {
40 template<class Subscriber>
41 typename std::enable_if<!std::is_same<Subscriber, subscriber<T>>::value, void>::type
42 on_subscribe(Subscriber o) const {
44 static_assert(is_subscriber<Subscriber>::value, "on_subscribe must be passed a subscriber.");
|
| /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);
|
| /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);
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| rx-subscribe.hpp | 7 \brief Subscribe will cause the source observable to emit values to the provided subscriber.
9 \tparam ArgN types of the subscriber parameters
11 \param an the parameters for making a subscriber
17 - Pass an already composed rxcpp::subscriber:
18 \snippet subscribe.cpp subscribe by subscriber
19 \snippet output.txt subscribe by subscriber
21 - Pass an rxcpp::observer. This allows subscribing the same subscriber to several observables:
46 If neither subscription nor subscriber are provided, then a new subscription is created and returned as a result:
64 template<class Subscriber>
68 class subscribe_factory<subscriber<T, I>
[all...] |
| rx-ignore_elements.hpp | 41 template<class Subscriber>
44 typedef ignore_elements_observer<Subscriber> this_type;
46 typedef rxu::decay_t<Subscriber> dest_type;
67 static subscriber<value_type, observer_type> make(dest_type d) {
72 template<class Subscriber>
73 auto operator()(Subscriber dest) const
74 -> decltype(ignore_elements_observer<Subscriber>::make(std::move(dest))) {
75 return ignore_elements_observer<Subscriber>::make(std::move(dest));
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| rx-behavior.hpp | 52 subscriber<T> get_subscriber() const {
88 subscriber<T> get_subscriber() const {
94 return make_observable_dynamic<T>([=](subscriber<T> o){
|
| rx-subject.hpp | 19 typedef subscriber<T> observer_type;
103 typedef subscriber<T, observer<T, detail::multicast_observer<T>>> input_subscriber_type;
242 typedef subscriber<T, observer<T, detail::multicast_observer<T>>> subscriber_type;
267 return make_observable_dynamic<T>([=](subscriber<T> o){
|
| rx-synchronize.hpp | 24 typedef typename coordinator_type::template get<subscriber<T>>::type output_type;
145 subscriber<T> get_subscriber() const {
178 subscriber<T> get_subscriber() const {
184 return make_observable_dynamic<T>([=](subscriber<T> o){
222 template<class Subscriber>
223 auto out(Subscriber s) const
224 -> Subscriber {
|
| rx-replaysubject.hpp | 106 subscriber<T> get_subscriber() const {
166 subscriber<T> get_subscriber() const {
172 auto observable = make_observable_dynamic<T>([=](subscriber<T> o){
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/cep/ |
| main.cpp | 20 [](rx::subscriber<int> dest){
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/ |
| create.cpp | 16 [&](const rx::subscriber<int>& s){
55 [&](const rx::subscriber<int>& so){
|
| /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...] |
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| subscription.cpp | 14 auto observers = std::make_shared<std::list<rxcpp::subscriber<int>>>();
16 auto observable = rxcpp::observable<>::create<int>([=](rxcpp::subscriber<int> out){
130 auto liftrequirecompletion = [&](rx::subscriber<int> dest){
131 auto completionstate = std::make_shared<std::tuple<bool, long, rx::subscriber<int>>>(false, 0, std::move(dest));
239 auto liftrequirecompletion = [&](rx::subscriber<int> dest){
240 auto completionstate = std::make_shared<std::tuple<bool, long, rx::subscriber<int>>>(false, 0, std::move(dest));
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| rx-test.hpp | 122 subscriber<T, rxt::testable_observer<T>> make_subscriber() const;
175 virtual void on_subscribe(subscriber<T>) const {
188 subscriber<T, rxt::testable_observer<T>> test_type::test_type_worker::make_subscriber() const
244 virtual void on_subscribe(subscriber<T> o) const {
288 typedef subscriber<T> observer_type;
467 -> subscriber<T, rxt::testable_observer<T>>
475 subscriber<T, rxt::testable_observer<T>> o;
477 explicit state_type(subscriber<T, rxt::testable_observer<T>> o)
502 -> subscriber<T, rxt::testable_observer<T>>
509 -> subscriber<T, rxt::testable_observer<T>
[all...] |
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/win_text/ |
| rx_windows_user.h | 62 subscriber<Message> sub;
|
