| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscriber.hpp | 25 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 …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 91 val subscriber = ReactiveSubscriber<T>(capacity, onBufferOverflow, requestSize) in <lambda>() constant
93 publisher.injectCoroutineContext(injectContext).subscribe(subscriber) in <lambda>()
97 val value = subscriber.takeNextOrNull() ?: break in <lambda>()
102 subscriber.makeRequest() in <lambda>()
106 subscriber.cancel() in <lambda>()
175 override fun subscribe(subscriber: Subscriber<in T>?) { in subscribe()
176 if (subscriber == null) throw NullPointerException() in subscribe()
177 subscriber.onSubscribe(FlowSubscription(flow, subscriber, context)) in subscribe()
185 @JvmField public val subscriber: Subscriber<in T>, constant in FlowSubscription
199 subscriber.onComplete() in flowProcessing()
[all …]
|
| D | Publish.kt | 64 ): Publisher<T> = Publisher { subscriber -> in publish() method
66 if (subscriber == null) throw NullPointerException("Subscriber cannot be null") in publish()
68 val coroutine = PublisherCoroutine(newContext, subscriber, exceptionOnCancelHandler) in publish()
69 …subscriber.onSubscribe(coroutine) // do it first (before starting coroutine), to avoid unnecessary… in publish()
81 private val subscriber: Subscriber<T>, constant
152 subscriber.onNext(elem) in doLockedNext()
217 subscriber.onError(cause) in doLockedSignalCompleted()
222 subscriber.onComplete() in doLockedSignalCompleted()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | create.cpp | 9 [](rxcpp::subscriber<int> s){ in __anona11559230102()
25 auto subscriber = rxcpp::make_subscriber<int>( variable
36 [](rxcpp::subscriber<int> s){ in __anona11559230602()
43 }).subscribe(subscriber); in __anona11559230602()
50 auto subscriber = rxcpp::make_subscriber<int>( variable
61 [](rxcpp::subscriber<int> s){ in __anona11559230902()
70 }).subscribe(subscriber); in __anona11559230902()
77 [](rxcpp::subscriber<int> s){ in __anona11559230a02()
|
| D | subscribe.cpp | 8 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/openscreen/platform/impl/ |
| D | socket_handle_waiter_posix_unittest.cc | 49 MockSubscriber subscriber; in TEST() local
58 waiter.Subscribe(&subscriber, std::cref(handle0_ref)); in TEST()
59 waiter.Subscribe(&subscriber, std::cref(handle1_ref)); in TEST()
60 waiter.Subscribe(&subscriber, std::cref(handle2_ref)); in TEST()
62 EXPECT_CALL(subscriber, ProcessReadyHandle(_, _)).Times(0); in TEST()
69 MockSubscriber subscriber; in TEST() local
81 waiter.Subscribe(&subscriber, std::cref(handle0_ref)); in TEST()
82 waiter.Subscribe(&subscriber, std::cref(handle2_ref)); in TEST()
89 EXPECT_CALL(subscriber, ProcessReadyHandle(std::cref(handle0_ref), r_flags)) in TEST()
91 EXPECT_CALL(subscriber, ProcessReadyHandle(std::cref(handle2_ref), w_flags)) in TEST()
|
| D | socket_handle_waiter.cc | 18 void SocketHandleWaiter::Subscribe(Subscriber* subscriber, in Subscribe() argument
22 handle_mappings_.emplace(handle, SocketSubscription{subscriber}); in Subscribe()
26 void SocketHandleWaiter::Unsubscribe(Subscriber* subscriber, in Unsubscribe() argument
35 void SocketHandleWaiter::UnsubscribeAll(Subscriber* subscriber) { in UnsubscribeAll() argument
38 if (it->second.subscriber == subscriber) { in UnsubscribeAll()
46 void SocketHandleWaiter::OnHandleDeletion(Subscriber* subscriber, in OnHandleDeletion() argument
103 oldest_handle.subscription->subscriber->ProcessReadyHandle( in ProcessReadyHandles()
|
| D | socket_handle_waiter.h | 49 void Subscribe(Subscriber* subscriber, SocketHandleRef handle);
53 void Unsubscribe(Subscriber* subscriber, SocketHandleRef handle);
57 void UnsubscribeAll(Subscriber* subscriber);
61 void OnHandleDeletion(Subscriber* subscriber,
86 Subscriber* subscriber = nullptr; member
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxMaybe.kt | 33 ): Maybe<T> = Maybe.create { subscriber -> in rxMaybeInternal() method
35 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybeInternal()
36 subscriber.setCancellable(RxCancellable(coroutine)) in rxMaybeInternal()
42 private val subscriber: MaybeEmitter<T> constant
46 if (value == null) subscriber.onComplete() else subscriber.onSuccess(value) in onCompleted()
54 if (!subscriber.tryOnError(cause)) { in onCancelled()
|
| D | RxCompletable.kt | 32 ): Completable = Completable.create { subscriber -> in rxCompletableInternal() method
34 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletableInternal()
35 subscriber.setCancellable(RxCancellable(coroutine)) in rxCompletableInternal()
41 private val subscriber: CompletableEmitter constant
45 subscriber.onComplete() in onCompleted()
53 if (!subscriber.tryOnError(cause)) { in onCancelled()
|
| D | RxSingle.kt | 32 ): Single<T> = Single.create { subscriber -> in rxSingleInternal() method
34 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingleInternal()
35 subscriber.setCancellable(RxCancellable(coroutine)) in rxSingleInternal()
41 private val subscriber: SingleEmitter<T> constant
45 subscriber.onSuccess(value) in onCompleted()
53 if (!subscriber.tryOnError(cause)) { in onCancelled()
|
| D | RxObservable.kt | 46 ): Observable<T> = Observable.create { subscriber -> in rxObservableInternal() method
48 val coroutine = RxObservableCoroutine(newContext, subscriber) in rxObservableInternal()
49 …subscriber.setCancellable(RxCancellable(coroutine)) // do it first (before starting coroutine), to… in rxObservableInternal()
59 private val subscriber: ObservableEmitter<T> constant
113 subscriber.onNext(elem) in doLockedNext()
157 subscriber.tryOnError(cause) in doLockedSignalCompleted()
163 subscriber.onComplete() in doLockedSignalCompleted()
|
| /external/arm-trusted-firmware/include/lib/el3_runtime/ |
| D | pubsub.h | 82 #define for_each_subscriber(event, subscriber) \ argument
83 for (subscriber = __pubsub_start_sym(event); \
84 subscriber < __pubsub_end_sym(event); \
85 subscriber++)
93 pubsub_cb_t *subscriber; \
94 for_each_subscriber(event, subscriber) { \
95 (*subscriber)(arg); \
|
| /external/ims/rcs/rcsservice/src/com/android/service/ims/presence/ |
| D | PresenceSubscriber.java | 63 public PresenceSubscriber(SubscribePublisher subscriber, Context context, in PresenceSubscriber() argument
68 this.mSubscriber = subscriber; in PresenceSubscriber()
75 public void updatePresenceSubscriber(SubscribePublisher subscriber) { in updatePresenceSubscriber() argument
78 this.mSubscriber = subscriber; in updatePresenceSubscriber()
127 SubscribePublisher subscriber = null; in requestCapability() local
129 subscriber = mSubscriber; in requestCapability()
132 if (subscriber == null) { in requestCapability()
143 int ret = subscriber.getStackStatusForCapabilityRequest(); in requestCapability()
188 ret = subscriber.requestCapability(formatedContacts, taskId); in requestCapability()
247 SubscribePublisher subscriber = null; in requestAvailability() local
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxMaybe.kt | 47 ): Maybe<T> = Maybe.create { subscriber -> in rxMaybe() method
49 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybe()
50 subscriber.setCancellable(RxCancellable(coroutine)) in rxMaybe()
56 private val subscriber: MaybeEmitter<T> constant
60 if (value == null) subscriber.onComplete() else subscriber.onSuccess(value) in onCompleted()
68 if (!subscriber.tryOnError(cause)) { in onCancelled()
|
| D | RxCompletable.kt | 46 ): Completable = Completable.create { subscriber -> in rxCompletable() method
48 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletable()
49 subscriber.setCancellable(RxCancellable(coroutine)) in rxCompletable()
55 private val subscriber: CompletableEmitter constant
59 subscriber.onComplete() in onCompleted()
67 if (!subscriber.tryOnError(cause)) { in onCancelled()
|
| D | RxSingle.kt | 46 ): Single<T> = Single.create { subscriber -> in rxSingle() method
48 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingle()
49 subscriber.setCancellable(RxCancellable(coroutine)) in rxSingle()
55 private val subscriber: SingleEmitter<T> constant
59 subscriber.onSuccess(value) in onCompleted()
67 if (!subscriber.tryOnError(cause)) { in onCancelled()
|
| D | RxObservable.kt | 60 ): Observable<T> = Observable.create { subscriber -> in rxObservable() method
62 val coroutine = RxObservableCoroutine(newContext, subscriber) in rxObservable()
63 …subscriber.setCancellable(RxCancellable(coroutine)) // do it first (before starting coroutine), to… in rxObservable()
73 private val subscriber: ObservableEmitter<T> constant
127 subscriber.onNext(elem) in doLockedNext()
171 subscriber.tryOnError(cause) in doLockedSignalCompleted()
177 subscriber.onComplete() in doLockedSignalCompleted()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | ReactorFlow.kt | 35 override fun subscribe(subscriber: CoreSubscriber<in T>?) { in asFlux()
36 if (subscriber == null) throw NullPointerException() in asFlux()
37 val hasContext = !subscriber.currentContext().isEmpty in asFlux()
38 …val source = if (hasContext) flow.flowOn(subscriber.currentContext().asCoroutineContext()) else fl… in asFlux()
39 subscriber.onSubscribe(FlowSubscription(source, subscriber, context)) in asFlux()
|
| D | Flux.kt | 62 ): Publisher<T> = Publisher { subscriber -> in flux() method
64 if (subscriber == null) throw NullPointerException("Subscriber cannot be null") in flux()
65 …require(subscriber is CoreSubscriber) { "Subscriber is not an instance of CoreSubscriber, context … in flux()
66 val currentContext = subscriber.currentContext() in flux()
69 val coroutine = PublisherCoroutine(newContext, subscriber, REACTOR_HANDLER) in flux()
70 …subscriber.onSubscribe(coroutine) // do it first (before starting coroutine), to avoid unnecessary… in flux()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | ConflatedBroadcastChannel.kt | 101 val subscriber = Subscriber(this) in <lambda>() constant
105 subscriber.close(state.closeCause) in <lambda>()
106 return subscriber in <lambda>()
110 subscriber.offerInternal(state.value as E) in <lambda>()
111 … val update = State(state.value, addSubscriber((state as State<E>).subscribers, subscriber)) in <lambda>()
113 return subscriber in <lambda>()
121 private fun closeSubscriber(subscriber: Subscriber<E>) { in <lambda>()
126 … val update = State(state.value, removeSubscriber((state as State<E>).subscribers!!, subscriber)) in <lambda>()
135 …private fun addSubscriber(list: Array<Subscriber<E>>?, subscriber: Subscriber<E>): Array<Subscribe… in <lambda>()
136 if (list == null) return Array(1) { subscriber } in <lambda>()
[all …]
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | SubscriberExceptionContext.java | 29 private final Object subscriber; field in SubscriberExceptionContext
40 EventBus eventBus, Object event, Object subscriber, Method subscriberMethod) { in SubscriberExceptionContext() argument
43 this.subscriber = checkNotNull(subscriber); in SubscriberExceptionContext()
62 return subscriber; in getSubscriber()
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | SubscriberExceptionContext.java | 29 private final Object subscriber; field in SubscriberExceptionContext
40 EventBus eventBus, Object event, Object subscriber, Method subscriberMethod) { in SubscriberExceptionContext() argument
43 this.subscriber = checkNotNull(subscriber); in SubscriberExceptionContext()
62 return subscriber; in getSubscriber()
|
| /external/guava/android/guava-tests/test/com/google/common/eventbus/ |
| D | SubscriberTest.java | 58 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_basicMethodCall() local
60 subscriber.invokeSubscriberMethod(FIXTURE_ARGUMENT); in testInvokeSubscriberMethod_basicMethodCall()
70 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_exceptionWrapping() local
73 subscriber.invokeSubscriberMethod(FIXTURE_ARGUMENT); in testInvokeSubscriberMethod_exceptionWrapping()
82 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_errorPassthrough() local
85 subscriber.invokeSubscriberMethod(FIXTURE_ARGUMENT); in testInvokeSubscriberMethod_errorPassthrough()
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | SubscriberTest.java | 58 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_basicMethodCall() local
60 subscriber.invokeSubscriberMethod(FIXTURE_ARGUMENT); in testInvokeSubscriberMethod_basicMethodCall()
70 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_exceptionWrapping() local
73 subscriber.invokeSubscriberMethod(FIXTURE_ARGUMENT); in testInvokeSubscriberMethod_exceptionWrapping()
82 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_errorPassthrough() local
85 subscriber.invokeSubscriberMethod(FIXTURE_ARGUMENT); in testInvokeSubscriberMethod_errorPassthrough()
|