| /aosp_15_r20/external/perfetto/ui/src/base/ |
| H A D | store.ts | 101 subscribe(callback: Callback<T>): Disposable; method
149 subscribe(callback: Callback<T>): Disposable { method in RootStore
257 subscribe(callback: Callback<T>): Disposable { method in SubStore
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| H A D | Migration.kt | 151 public fun <T> Flow<T>.subscribe(): Unit = noImpl() in <lambda>() method
160 )public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit): Unit = noImpl() in <lambda>() method
169 )public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit, onError: suspend (Throwable) -> Unit… in <lambda>() method
|
| /aosp_15_r20/tools/netsim/rust/daemon/src/ |
| H A D | events.rs | 34 pub fn subscribe() -> Receiver<Event> { in subscribe() function
123 fn subscribe(&mut self) -> Receiver<Event> { in subscribe() method
155 pub fn subscribe(s: &mut Arc<Mutex<Events>>) -> Receiver<Event> { in subscribe() function
|
| /aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ |
| H A D | ResponseHandler.java | 293 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in ResponseHandler.PublisherAdapter
434 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in ResponseHandler.FullResponseContentPublisher
494 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe() method in ResponseHandler.DataCountingPublisher
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/moqt/ |
| H A D | moqt_parser_test.cc | 606 char subscribe[] = { in TEST_F() local
708 char subscribe[] = { in TEST_F() local
728 char subscribe[] = { in TEST_F() local
748 char subscribe[] = { in TEST_F() local
805 char subscribe[] = { in TEST_F() local
|
| H A D | moqt_session.cc | 321 ActiveSubscribe& subscribe = subscribe_it->second; in TrackPropertiesFromAlias() local
673 MoqtSubscribe& subscribe = it->second.message; in OnSubscribeOkMessage() local
714 MoqtSubscribe& subscribe = it->second.message; in OnSubscribeErrorMessage() local
|
| H A D | moqt_session_test.cc | 106 MoqtSubscribe& subscribe, in AddActiveSubscribe()
646 MoqtSubscribe subscribe = { in TEST_F() local
701 MoqtSubscribe subscribe = { in TEST_F() local
760 MoqtSubscribe subscribe = { in TEST_F() local
810 MoqtSubscribe subscribe = { in TEST_F() local
|
| /aosp_15_r20/frameworks/base/packages/SystemUI/src/com/android/systemui/controls/controller/ |
| H A D | ControlsBindingController.kt | 74 fun subscribe(structureInfo: StructureInfo) in bindAndLoad() method
|
| H A D | ServiceWrapper.kt | 59 fun subscribe(controlIds: List<String>, subscriber: IControlsSubscriber): Boolean { in subscribe() method
|
| /aosp_15_r20/packages/services/Car/car-lib/src/android/car/vms/ |
| D | VmsSubscriptionHelper.java | 62 public void subscribe(@NonNull VmsLayer layer) { in subscribe() method in VmsSubscriptionHelper
75 public void subscribe(@NonNull VmsLayer layer, int providerId) { in subscribe() method in VmsSubscriptionHelper
|
| D | VmsSubscriberManager.java | 179 public void subscribe(@NonNull VmsLayer layer) { in subscribe() method in VmsSubscriberManager
191 public void subscribe(@NonNull VmsLayer layer, int publisherId) { in subscribe() method in VmsSubscriberManager
|
| D | VmsOperationRecorder.java | 68 public void subscribe(VmsLayer layer) { in subscribe() method in VmsOperationRecorder
83 public void subscribe(VmsLayer layer, int publisherId) { in subscribe() method in VmsOperationRecorder
|
| /aosp_15_r20/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/audio_util/mockable/ |
| D | MediaBrowser.java | 111 public void subscribe(String parentId, Bundle options, SubscriptionCallback callback) { in subscribe() method in MediaBrowser
116 public void subscribe(String parentId, SubscriptionCallback callback) { in subscribe() method in MediaBrowser
|
| /aosp_15_r20/system/netd/server/ |
| H A D | NFLogListenerTest.cpp | 79 void subscribe(uint16_t type, const NFLogListenerInterface::DispatchFn& fn) { in subscribe() function in android::net::NFLogListenerTest
104 TEST_F(NFLogListenerTest, subscribe) { in TEST_F() argument
|
| H A D | NFLogListener.cpp | 177 Status NFLogListener::subscribe(uint16_t nfLogGroup, const DispatchFn& fn) { in subscribe() function in android::net::NFLogListener
181 Status NFLogListener::subscribe( in subscribe() function in android::net::NFLogListener
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/ |
| H A D | SplittingPublisher.java | 73 public void subscribe(Subscriber<? super AsyncRequestBody> downstreamSubscriber) { in subscribe() method in SplittingPublisher
290 public void subscribe(Subscriber<? super ByteBuffer> s) { in subscribe() method in SplittingPublisher.SplittingSubscriber.DownstreamBody
|
| /aosp_15_r20/frameworks/base/media/java/android/media/browse/ |
| H A D | MediaBrowser.java | 359 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
|
| /aosp_15_r20/external/python/bumble/bumble/ |
| D | gatt_client.py | 205 async def subscribe( member in CharacteristicProxy
806 async def subscribe( member in Client
|
| /aosp_15_r20/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/ |
| H A D | MqttClientConnection.java | 350 …public CompletableFuture<Integer> subscribe(String topic, QualityOfService qos, Consumer<MqttMessa… in subscribe() method in MqttClientConnection
378 public CompletableFuture<Integer> subscribe(String topic, QualityOfService qos) { in subscribe() method in MqttClientConnection
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/async/ |
| H A D | EmptyPublisher.java | 36 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() method in EmptyPublisher
|
| /aosp_15_r20/external/aws-sdk-java-v2/test/ruleset-testing-core/src/main/java/software/amazon/awssdk/core/rules/testing/util/ |
| H A D | EmptyPublisher.java | 24 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() method in EmptyPublisher
|
| /aosp_15_r20/hardware/interfaces/automotive/vehicle/2.0/default/tests/ |
| H A D | VehicleHalManager_test.cpp | 108 StatusCode subscribe(int32_t /* property */, in subscribe() function in android::hardware::automotive::vehicle::V2_0::__anon9b081d250111::MockedVehicleHal
265 TEST_F(VehicleHalManagerTest, subscribe) { in TEST_F() argument
|
| /aosp_15_r20/out/soong/.intermediates/hardware/interfaces/automotive/vehicle/2.0/android.hardware.automotive.vehicle-V2.0-java_gen_java/gen/srcs/android/hardware/automotive/vehicle/V2_0/ |
| D | IVehicle.java | 153 …int subscribe(android.hardware.automotive.vehicle.V2_0.IVehicleCallback callback, java.util.ArrayL… in subscribe() method
405 …public int subscribe(android.hardware.automotive.vehicle.V2_0.IVehicleCallback callback, java.util… in subscribe() method in IVehicle.Proxy
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/crt/ |
| H A D | S3MetaRequestPauseObservable.java | 39 public void subscribe(S3MetaRequest request) { in subscribe() method in S3MetaRequestPauseObservable
|
| /aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/nrs/ |
| H A D | DelegateStreamedHttpRequest.java | 43 public void subscribe(Subscriber<? super HttpContent> subscriber) { in subscribe() method in DelegateStreamedHttpRequest
|