| /external/openscreen/platform/impl/ |
| D | socket_handle_waiter.cc | 18 void SocketHandleWaiter::Subscribe(Subscriber* subscriber, in Subscribe()
26 void SocketHandleWaiter::Unsubscribe(Subscriber* subscriber, in Unsubscribe()
35 void SocketHandleWaiter::UnsubscribeAll(Subscriber* subscriber) { in UnsubscribeAll()
46 void SocketHandleWaiter::OnHandleDeletion(Subscriber* subscriber, in OnHandleDeletion()
|
| D | socket_handle_waiter_posix_unittest.cc | 49 MockSubscriber subscriber; in TEST() local
69 MockSubscriber subscriber; in TEST() local
|
| D | socket_handle_waiter.h | 86 Subscriber* subscriber = nullptr; member
|
| /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
70 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_exceptionWrapping() local
82 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_errorPassthrough() local
|
| D | EventBusTest.java | 123 final Object subscriber = in testSubscriberThrowsException() local
152 final Object subscriber = in testSubscriberThrowsExceptionHandlerThrowsException() local
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | SubscriberTest.java | 58 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_basicMethodCall() local
70 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_exceptionWrapping() local
82 Subscriber subscriber = Subscriber.create(bus, this, method); in testInvokeSubscriberMethod_errorPassthrough() local
|
| D | EventBusTest.java | 123 final Object subscriber = in testSubscriberThrowsException() local
152 final Object subscriber = in testSubscriberThrowsExceptionHandlerThrowsException() local
|
| /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()
|
| D | Dispatcher.java | 169 private final Subscriber subscriber; field in Dispatcher.LegacyAsyncDispatcher.EventWithSubscriber
171 private EventWithSubscriber(Object event, Subscriber subscriber) { in EventWithSubscriber()
|
| /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()
|
| D | Dispatcher.java | 169 private final Subscriber subscriber; field in Dispatcher.LegacyAsyncDispatcher.EventWithSubscriber
171 private EventWithSubscriber(Object event, Subscriber subscriber) { in EventWithSubscriber()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxMaybe.kt | 33 ): Maybe<T> = Maybe.create { subscriber -> in rxMaybeInternal() method
42 private val subscriber: MaybeEmitter<T> constant
|
| D | RxSingle.kt | 32 ): Single<T> = Single.create { subscriber -> in rxSingleInternal() method
41 private val subscriber: SingleEmitter<T> constant
|
| D | RxCompletable.kt | 32 ): Completable = Completable.create { subscriber -> in rxCompletableInternal() method
41 private val subscriber: CompletableEmitter constant
|
| D | RxObservable.kt | 46 ): Observable<T> = Observable.create { subscriber -> in rxObservableInternal() method
59 private val subscriber: ObservableEmitter<T> constant
|
| /external/ims/rcs/rcsservice/src/com/android/service/ims/presence/ |
| D | PresenceSubscriber.java | 63 public PresenceSubscriber(SubscribePublisher subscriber, Context context, in PresenceSubscriber()
75 public void updatePresenceSubscriber(SubscribePublisher subscriber) { in updatePresenceSubscriber()
127 SubscribePublisher subscriber = null; in requestCapability() local
247 SubscribePublisher subscriber = null; in requestAvailability() local
383 SubscribePublisher subscriber = null; in onSipResponse() local
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxMaybe.kt | 47 ): Maybe<T> = Maybe.create { subscriber -> in rxMaybe() method
56 private val subscriber: MaybeEmitter<T> constant
|
| D | RxSingle.kt | 46 ): Single<T> = Single.create { subscriber -> in rxSingle() method
55 private val subscriber: SingleEmitter<T> constant
|
| D | RxCompletable.kt | 46 ): Completable = Completable.create { subscriber -> in rxCompletable() method
55 private val subscriber: CompletableEmitter constant
|
| D | RxObservable.kt | 60 ): Observable<T> = Observable.create { subscriber -> in rxObservable() method
73 private val subscriber: ObservableEmitter<T> constant
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | create.cpp | 25 auto subscriber = rxcpp::make_subscriber<int>( variable
50 auto subscriber = rxcpp::make_subscriber<int>( variable
|
| D | subscribe.cpp | 8 auto subscriber = rxcpp::make_subscriber<int>( variable
18 auto subscriber = rxcpp::make_subscriber<int>( variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 91 val subscriber = ReactiveSubscriber<T>(capacity, onBufferOverflow, requestSize) in <lambda>() constant
185 @JvmField public val subscriber: Subscriber<in T>, constant in FlowSubscription
|
| D | Publish.kt | 64 ): Publisher<T> = Publisher { subscriber -> in publish() method
81 private val subscriber: Subscriber<T>, constant
|
| /external/tensorflow/tensorflow/core/profiler/internal/gpu/ |
| D | cupti_wrapper.cc | 70 CUpti_SubscriberHandle subscriber, in EnableCallback()
77 CUpti_SubscriberHandle subscriber, in EnableDomain()
82 CUptiResult CuptiWrapper::Subscribe(CUpti_SubscriberHandle* subscriber, in Subscribe()
88 CUptiResult CuptiWrapper::Unsubscribe(CUpti_SubscriberHandle subscriber) { in Unsubscribe()
|