| /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
|
| /external/rust/crates/tracing/tests/ |
| D | enabled.rs | 8 let subscriber = subscriber::mock() in level_and_target() localVariable
29 let subscriber = subscriber::mock() in span_and_event() localVariable
|
| D | subscriber.rs | 75 let subscriber: Box<dyn Subscriber + Send + Sync + 'static> = Box::new(subscriber); in boxed_subscriber() localVariable
112 let subscriber: Arc<dyn Subscriber + Send + Sync + 'static> = Arc::new(subscriber); in arced_subscriber() localVariable
|
| D | filter_caching_is_lexically_scoped.rs | 32 let subscriber = subscriber::mock() in filter_caching_is_lexically_scoped() localVariable
|
| D | filters_are_reevaluated_for_different_call_sites.rs | 27 let subscriber = subscriber::mock() in filters_are_reevaluated_for_different_call_sites() localVariable
|
| /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
|
| /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
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | SubscriberExceptionContext.java | 30 private final Object subscriber; field in SubscriberExceptionContext
41 EventBus eventBus, Object event, Object subscriber, Method subscriberMethod) { in SubscriberExceptionContext()
|
| D | Dispatcher.java | 170 private final Subscriber subscriber; field in Dispatcher.LegacyAsyncDispatcher.EventWithSubscriber
172 private EventWithSubscriber(Object event, Subscriber subscriber) { in EventWithSubscriber()
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | SubscriberExceptionContext.java | 30 private final Object subscriber; field in SubscriberExceptionContext
41 EventBus eventBus, Object event, Object subscriber, Method subscriberMethod) { in SubscriberExceptionContext()
|
| D | Dispatcher.java | 170 private final Subscriber subscriber; field in Dispatcher.LegacyAsyncDispatcher.EventWithSubscriber
172 private EventWithSubscriber(Object event, Subscriber subscriber) { in EventWithSubscriber()
|
| /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-rx3/src/ |
| 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
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/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
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherCollectTest.kt | 19 val publisher = Publisher<Int> { subscriber -> in <lambda>() method
60 val publisher = Publisher<Int> { subscriber -> in <lambda>() method
102 val publisher = Publisher<Int> { subscriber -> in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherCollectTest.kt | 21 val publisher = JFlow.Publisher<Int> { subscriber -> in <lambda>() method
62 val publisher = Publisher<Int> { subscriber -> in <lambda>() method
104 val publisher = Publisher<Int> { subscriber -> in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 92 val subscriber = ReactiveSubscriber<T>(capacity, onBufferOverflow, requestSize) in <lambda>() constant
190 @JvmField public val subscriber: Subscriber<in T>, constant in FlowSubscription
|
| /external/guava/guava-tests/test/com/google/common/eventbus/outside/ |
| D | AbstractEventBusTest.java | 37 private H subscriber; field in AbstractEventBusTest
|
| D | BaseSubscriberFinderTest.java | 36 public void subscriber(Object o) { in subscriber() method in BaseSubscriberFinderTest.Subscriber
|
| /external/guava/android/guava-tests/test/com/google/common/eventbus/outside/ |
| D | AbstractEventBusTest.java | 37 private H subscriber; field in AbstractEventBusTest
|
| /external/tensorflow/tensorflow/core/profiler/backends/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()
|