Home
last modified time | relevance | path

Searched refs:subscriber (Results 1 – 25 of 71) sorted by relevance

123

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-subscriber.hpp25 class subscriber : public subscriber_base<T> class
29 typedef subscriber<T, Observer> this_type;
103 subscriber();
107 subscriber(const this_type& o) in subscriber() function in rxcpp::subscriber
113 subscriber(this_type&& o) in subscriber() function in rxcpp::subscriber
121 friend class subscriber;
124 subscriber( in subscriber() function in rxcpp::subscriber
125 const subscriber<T, O>& o, in subscriber()
136 subscriber(trace_id id, composite_subscription cs, U&& o) in subscriber() function in rxcpp::subscriber
169 subscriber<T> as_dynamic() const { in as_dynamic()
[all …]
Drx-test.hpp22 virtual void on_subscribe(subscriber<T>) const =0;
37 void on_subscribe(subscriber<T> o) const { in on_subscribe()
41 typename std::enable_if<!std::is_same<Subscriber, subscriber<T>>::value, void>::type
Drx-observable.hpp42 typedef std::function<void(subscriber<T>)> onsubscribe_type;
54 state->on_subscribe = [so](subscriber<T> o) mutable { in construct()
81 void on_subscribe(subscriber<T> o) const { in on_subscribe()
514 … detail::safe_subscriber<source_operator_type, subscriber_type> subscriber(source_operator, o); in detail_subscribe() local
519 sc.create_worker(o.get_subscription()).schedule(subscriber); in detail_subscribe()
522 subscriber.subscribe(); in detail_subscribe()
617 …static_assert(detail::is_lift_function_for<T, subscriber<ResultType>, Operator>::value, "Function … in lift()
627 …-> typename std::enable_if<detail::is_lift_function_for<T, subscriber<ResultType>, Operator>::valu… in lift_if()
639 …-> typename std::enable_if<!detail::is_lift_function_for<T, subscriber<ResultType>, Operator>::val… in lift_if()
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Dcreate.cpp9 [](rxcpp::subscriber<int> s){ in __anon37f8ac850102()
25 auto subscriber = rxcpp::make_subscriber<int>( variable
36 [](rxcpp::subscriber<int> s){ in __anon37f8ac850602()
43 }).subscribe(subscriber); in __anon37f8ac850602()
50 auto subscriber = rxcpp::make_subscriber<int>( variable
61 [](rxcpp::subscriber<int> s){ in __anon37f8ac850902()
70 }).subscribe(subscriber); in __anon37f8ac850902()
77 [](rxcpp::subscriber<int> s){ in __anon37f8ac850a02()
Dsubscribe.cpp8 auto subscriber = rxcpp::make_subscriber<int>( variable
12 values.subscribe(subscriber);
18 auto subscriber = rxcpp::make_subscriber<int>( variable
23 values1.subscribe(subscriber.get_observer());
24 values2.subscribe(subscriber.get_observer());
/external/tensorflow/tensorflow/core/platform/default/gpu/
Dcupti_wrapper.cc106 CUpti_SubscriberHandle subscriber, in EnableCallback() argument
109 return dynload::cuptiEnableCallback(enable, subscriber, domain, cbid); in EnableCallback()
113 CUpti_SubscriberHandle subscriber, in EnableDomain() argument
115 return dynload::cuptiEnableDomain(enable, subscriber, domain); in EnableDomain()
118 CUptiResult CuptiWrapper::Subscribe(CUpti_SubscriberHandle* subscriber, in Subscribe() argument
121 return dynload::cuptiSubscribe(subscriber, callback, userdata); in Subscribe()
124 CUptiResult CuptiWrapper::Unsubscribe(CUpti_SubscriberHandle subscriber) { in Unsubscribe() argument
125 return dynload::cuptiUnsubscribe(subscriber); in Unsubscribe()
Dcupti_wrapper.h60 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/src/com/google/common/eventbus/
DAsyncEventBus.java85 void enqueueEvent(Object event, EventSubscriber subscriber) { in enqueueEvent() argument
86 eventsToDispatch.offer(new EventWithSubscriber(event, subscriber)); in enqueueEvent()
102 dispatch(eventWithSubscriber.event, eventWithSubscriber.subscriber); in dispatchQueuedEvents()
110 void dispatch(final Object event, final EventSubscriber subscriber) { in dispatch() argument
112 checkNotNull(subscriber); in dispatch()
117 AsyncEventBus.super.dispatch(event, subscriber); in dispatch()
DSubscriberExceptionContext.java30 private final Object subscriber; field in SubscriberExceptionContext
40 SubscriberExceptionContext(EventBus eventBus, Object event, Object subscriber, in SubscriberExceptionContext() argument
44 this.subscriber = checkNotNull(subscriber); in SubscriberExceptionContext()
67 return subscriber; in getSubscriber()
DEventBus.java283 void enqueueEvent(Object event, EventSubscriber subscriber) { in enqueueEvent() argument
284 eventsToDispatch.get().offer(new EventWithSubscriber(event, subscriber)); in enqueueEvent()
304 dispatch(eventWithSubscriber.event, eventWithSubscriber.subscriber); in dispatchQueuedEvents()
393 final EventSubscriber subscriber; field in EventBus.EventWithSubscriber
394 public EventWithSubscriber(Object event, EventSubscriber subscriber) { in EventWithSubscriber() argument
396 this.subscriber = checkNotNull(subscriber); in EventWithSubscriber()
DAnnotatedSubscriberFinder.java75 EventSubscriber subscriber = makeSubscriber(listener, method); in findAllSubscribers() local
76 methodsInListener.put(eventType, subscriber); in findAllSubscribers()
/external/guava/guava-tests/test/com/google/common/eventbus/
DEventSubscriberTest.java53 EventSubscriber subscriber = new EventSubscriber(this, method); in testBasicMethodCall() local
55 subscriber.handleEvent(FIXTURE_ARGUMENT); in testBasicMethodCall()
64 EventSubscriber subscriber = new EventSubscriber(this, method); in testExceptionWrapping() local
67 subscriber.handleEvent(new Object()); in testExceptionWrapping()
77 EventSubscriber subscriber = new EventSubscriber(this, method); in testErrorPassthrough() local
80 subscriber.handleEvent(new Object()); in testErrorPassthrough()
DEventBusTest.java130 final Object subscriber = new Object() { in testSubscriberThrowsException() local
136 eventBus.register(subscriber); in testSubscriberThrowsException()
147 subscriber, handler.context.getSubscriber()); in testSubscriberThrowsException()
149 subscriber.getClass().getMethod("throwExceptionOn", String.class), in testSubscriberThrowsException()
161 final Object subscriber = new Object() { in testSubscriberThrowsExceptionHandlerThrowsException() local
167 eventBus.register(subscriber); in testSubscriberThrowsExceptionHandlerThrowsException()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-test.hpp122 subscriber<T, rxt::testable_observer<T>> make_subscriber() const;
175 virtual void on_subscribe(subscriber<T>) const { in on_subscribe()
188 subscriber<T, rxt::testable_observer<T>> test_type::test_type_worker::make_subscriber() const in make_subscriber()
244 virtual void on_subscribe(subscriber<T> o) const { in on_subscribe()
288 typedef subscriber<T> observer_type;
467 -> subscriber<T, rxt::testable_observer<T>> in start()
475 subscriber<T, rxt::testable_observer<T>> o; in start()
477 explicit state_type(subscriber<T, rxt::testable_observer<T>> o) in start()
502 -> subscriber<T, rxt::testable_observer<T>> in start()
509 -> subscriber<T, rxt::testable_observer<T>> in start()
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-subscribe.hpp68 class subscribe_factory<subscriber<T, I>>
70 subscriber<T, I> scrbr;
72 subscribe_factory(subscriber<T, I> s) in subscribe_factory()
Drx-ignore_elements.hpp67 static subscriber<value_type, observer_type> make(dest_type d) { in make()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-behavior.hpp52 subscriber<T> get_subscriber() const { in get_subscriber()
88 subscriber<T> get_subscriber() const { in get_subscriber()
94 return make_observable_dynamic<T>([=](subscriber<T> o){ in get_observable()
Drx-subject.hpp19 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){ in get_observable()
Drx-synchronize.hpp24 typedef typename coordinator_type::template get<subscriber<T>>::type output_type;
145 subscriber<T> get_subscriber() const { in get_subscriber()
178 subscriber<T> get_subscriber() const { in get_subscriber()
184 return make_observable_dynamic<T>([=](subscriber<T> o){ in get_observable()
Drx-replaysubject.hpp106 subscriber<T> get_subscriber() const { in get_subscriber()
166 subscriber<T> get_subscriber() const { in get_subscriber()
172 auto observable = make_observable_dynamic<T>([=](subscriber<T> o){ in get_observable()
/external/guava/guava-tests/test/com/google/common/eventbus/outside/
DAnnotatedSubscriberFinderTests.java42 private H subscriber; field in AnnotatedSubscriberFinderTests.AbstractEventBusTest
45 return subscriber; in getSubscriber()
50 subscriber = createSubscriber(); in setUp()
52 bus.register(subscriber); in setUp()
58 subscriber = null; in tearDown()
76 public void subscriber(Object o) { in subscriber() method in AnnotatedSubscriberFinderTests.BaseSubscriberFinderTest.Subscriber
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/
Dsubscription.cpp14 auto observers = std::make_shared<std::list<rxcpp::subscriber<int>>>();
16 auto observable = rxcpp::observable<>::create<int>([=](rxcpp::subscriber<int> out){ in __anonfe564e910102()
130 auto liftrequirecompletion = [&](rx::subscriber<int> dest){ in __anonfe564e910a02()
131 …auto completionstate = std::make_shared<std::tuple<bool, long, rx::subscriber<int>>>(false, 0, std… in __anonfe564e910a02()
239 auto liftrequirecompletion = [&](rx::subscriber<int> dest){ in __anonfe564e911602()
240 …auto completionstate = std::make_shared<std::tuple<bool, long, rx::subscriber<int>>>(false, 0, std… in __anonfe564e911602()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dcreate.cpp16 [&](const rx::subscriber<int>& s){ in __anon44bf292c0102()
55 [&](const rx::subscriber<int>& so){ in __anon44bf292c0302()
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/cep/
Dmain.cpp20 [](rx::subscriber<int> dest){ in main()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dlift.cpp51 … static rx::subscriber<value_type, observer_type> make(const dest_type& d, const test_type& t) { in make()
244 .lift<int>([=](rx::subscriber<int> dest){ in __anon3192a8220602()

123