Home
last modified time | relevance | path

Searched refs:subscribe (Results 1 – 25 of 52) sorted by relevance

123

/frameworks/native/libs/bufferstreams/rust/src/
Dlib.rs62 fn subscribe(&mut self, subscriber: impl BufferSubscriber + 'static); in subscribe() method
210 publisher.subscribe(subscriber.clone()); in test_test_implementations_next()
232 publisher.subscribe(subscriber.clone()); in test_test_implementations_complete()
246 publisher.subscribe(subscriber.clone()); in test_test_implementations_error()
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/controls/controller/
DServiceWrapperTest.kt113 val result = wrapper.subscribe(list, subscriber) in testSubscribe_happyPath()
116 verify(service).subscribe(list, subscriber) in testSubscribe_happyPath()
121 `when`(service.subscribe(any(), any())).thenThrow(exception) in testSubscribe_error()
124 val result = wrapper.subscribe(list, subscriber) in testSubscribe_error()
DControlsBindingControllerImplTest.kt283 controller.subscribe(structure) in testSubscribe()
313 controller.subscribe(structure) in testUnsubscribe_refreshing()
/frameworks/base/services/tests/servicestests/src/com/android/server/biometrics/log/
DBiometricContextProviderTest.java207 mProvider.subscribe(mOpContext, mStartHalConsumer, ctx -> { in testSubscribesToFoldState()
235 mProvider.subscribe(mOpContext, mStartHalConsumer, ctx -> { in testSubscribesToDisplayState()
257 mProvider.subscribe(mOpContext, mStartHalConsumer, ctx -> { in testSubscribesToAod()
280 mProvider.subscribe(mOpContext, mStartHalConsumer, ctx -> { in testSubscribesToAwake()
302 mProvider.subscribe(mOpContext, mStartHalConsumer, nonEmptyConsumer, mAuthenticateOptions); in testSubscribesWithDifferentState()
310 mProvider.subscribe(mOpContext, mStartHalConsumer, emptyConsumer, mAuthenticateOptions); in testUnsubscribes()
319 mProvider.subscribe(mOpContext, mStartHalConsumer, nonEmptyConsumer, mAuthenticateOptions); in testUnsubscribes()
423 mProvider.subscribe(context, startHalConsumer, updateConsumer, options); in testSubscribe_thenStartHal()
438 assertThrows(IllegalStateException.class, () -> mProvider.subscribe( in testSubscribe_withInvalidOptions()
/frameworks/base/packages/SystemUI/src/com/android/systemui/controls/controller/
DServiceWrapper.kt59 fun subscribe(controlIds: List<String>, subscriber: IControlsSubscriber): Boolean { in subscribe() method in com.android.systemui.controls.controller.ServiceWrapper
61 service.subscribe(controlIds, subscriber) in subscribe()
DControlsBindingController.kt74 fun subscribe(structureInfo: StructureInfo) in bindAndLoad() method
/frameworks/native/libs/bufferstreams/rust/src/publishers/
Dbuffer_pool_publisher.rs62 fn subscribe(&mut self, subscriber: impl BufferSubscriber + 'static) { in subscribe() method
98 buffer_pool_publisher.subscribe(subscriber.clone()); in test_send_next_frame()
Dtesting.rs95 fn subscribe(&mut self, subscriber: impl BufferSubscriber + 'static) { in subscribe() method
/frameworks/base/core/java/android/service/controls/
DControlsProviderService.java225 public void subscribe(List<String> controlIds, in onBind() method in ControlsProviderService
261 ControlsProviderService.this.createPublisherForAllAvailable().subscribe(proxy);
275 publisher.subscribe(proxy);
286 .subscribe(proxy);
DIControlsProvider.aidl31 void subscribe(in List<String> controlIds, in subscribe() method
/frameworks/opt/net/ims/src/java/com/android/ims/rcs/uce/presence/subscribe/
DSubscribeController.java17 package com.android.ims.rcs.uce.presence.subscribe;
DSubscribeControllerImpl.java17 package com.android.ims.rcs.uce.presence.subscribe;
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/media/controls/domain/resume/
DResumeMediaBrowserTest.kt350 whenever(browser.subscribe(any(), capture(subscriptionCallback))).thenAnswer { in capture()
361 whenever(browser.subscribe(any(), capture(subscriptionCallback))).thenAnswer { in capture()
373 whenever(browser.subscribe(any(), capture(subscriptionCallback))).thenAnswer { in capture()
/frameworks/base/services/core/java/com/android/server/biometrics/log/
DBiometricContext.java93 void subscribe(@NonNull OperationContextExt context, in subscribe() method
DBiometricContextProvider.java231 public void subscribe(@NonNull OperationContextExt context, in subscribe() method in BiometricContextProvider
/frameworks/base/core/tests/coretests/src/android/service/controls/
DControlProviderServiceTest.java341 mControlsProvider.subscribe(new ArrayList<String>(), mSubscriber); in sendControlGetControl()
386 public void subscribe(final Subscriber s) { in createPublisherForAllAvailable()
395 public void subscribe(final Subscriber s) { in createPublisherFor()
404 public void subscribe(final Subscriber s) {
/frameworks/base/services/tests/servicestests/src/com/android/server/biometrics/sensors/fingerprint/aidl/
DFingerprintAuthenticationClientTest.java209 verify(mBiometricContext).subscribe(mOperationContextCaptor.capture(), in authNoContext_v1()
288 verify(mBiometricContext).subscribe(mOperationContextCaptor.capture(), in luxProbeWhenAwake()
334 verify(mBiometricContext).subscribe(mOperationContextCaptor.capture(), in luxProbeEnabledOnStart()
351 verify(mBiometricContext).subscribe(mOperationContextCaptor.capture(), in luxProbeDisabledOnAod()
389 verify(mBiometricContext).subscribe(mOperationContextCaptor.capture(), in subscribeContextAndStartHal()
DFingerprintDetectClientTest.java131 verify(mBiometricContext).subscribe(mOperationContextCaptor.capture(), in subscribeContextAndStartHal()
/frameworks/base/services/tests/servicestests/src/com/android/server/biometrics/sensors/face/aidl/
DFaceEnrollClientTest.java154 verify(mBiometricContext).subscribe( in subscribeContextAndStartHal()
183 verify(mBiometricContext).subscribe(mOperationContextCaptor.capture(), in enrollWithFaceOptionsAfterSubscribingContext()
/frameworks/base/services/core/java/com/android/server/biometrics/sensors/fingerprint/aidl/
DFingerprintDetectClient.java133 getBiometricContext().subscribe(opContext, ctx -> { in doDetectInteraction()
/frameworks/opt/telephony/flags/
Dims.aconfig82 description: "This flag controls whether framework supports SIP subscribe retry or not"
/frameworks/base/services/core/java/com/android/server/biometrics/sensors/face/aidl/
DFaceDetectClient.java160 getBiometricContext().subscribe(opContext, ctx -> { in doDetectInteraction()
/frameworks/base/packages/SystemUI/src/com/android/systemui/media/controls/domain/resume/
DResumeMediaBrowser.java170 mMediaBrowser.subscribe(root, mSubscriptionCallback);
/frameworks/opt/net/ims/src/java/com/android/ims/rcs/uce/request/
DSubscribeRequest.java35 import com.android.ims.rcs.uce.presence.subscribe.SubscribeController;
/frameworks/base/media/java/android/media/browse/
DMediaBrowser.java359 public void subscribe(@NonNull String parentId, @NonNull SubscriptionCallback callback) { in subscribe() method in MediaBrowser
385 public void subscribe(@NonNull String parentId, @NonNull Bundle options, in subscribe() method in MediaBrowser

123