| /aosp_15_r20/external/googleapis/google/pubsub/v1beta2/ |
| H A D | pubsub.proto | 28 service Subscriber { service
35 rpc CreateSubscription(Subscription) returns (Subscription);
38 rpc GetSubscription(GetSubscriptionRequest) returns (Subscription);
41 rpc ListSubscriptions(ListSubscriptionsRequest)
49 rpc DeleteSubscription(DeleteSubscriptionRequest)
56 rpc ModifyAckDeadline(ModifyAckDeadlineRequest)
66 rpc Acknowledge(AcknowledgeRequest) returns (google.protobuf.Empty);
72 rpc Pull(PullRequest) returns (PullResponse);
81 rpc ModifyPushConfig(ModifyPushConfigRequest) returns (google.protobuf.Empty);
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/tests/ |
| D | task.rs | 253 pub(crate) struct Subscriber { in spawn_niche_in_task() struct
254 state: Arc<Mutex<State>>, in spawn_niche_in_task()
255 observed_version: u64, in spawn_niche_in_task()
256 waker_key: Option<usize>, in spawn_niche_in_task()
259 impl Subscriber { in spawn_niche_in_task() impl
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/fmt/ |
| D | mod.rs | 225 pub struct Subscriber< struct
234 /// A `Subscriber` that logs formatted representations of `tracing` events. argument
338 impl Subscriber { implementation
359 impl Default for Subscriber { implementation
367 impl<N, E, F, W> tracing_core::Subscriber for Subscriber<N, E, F, W> implementation
451 impl<'a, N, E, F, W> LookupSpan<'a> for Subscriber<N, E, F, W> implementation
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/filter/ |
| D | mod.rs | 53 S: tracing_core::Subscriber, in subscriber_has_plf()
62 S: tracing_core::Subscriber, in layer_has_plf()
|
| /aosp_15_r20/external/guava/android/guava/src/com/google/common/eventbus/ |
| H A D | Subscriber.java | 36 class Subscriber { class
57 private Subscriber(EventBus bus, Object target, Method method) { in Subscriber() method in Subscriber
|
| /aosp_15_r20/external/guava/guava/src/com/google/common/eventbus/ |
| H A D | Subscriber.java | 36 class Subscriber { class
57 private Subscriber(EventBus bus, Object target, Method method) { in Subscriber() method in Subscriber
|
| /aosp_15_r20/prebuilts/tools/common/m2/repository/org/reactivestreams/reactive-streams/1.0.2/ |
| HD | reactive-streams-1.0.2.jar | META-INF/
META-INF/MANIFEST.MF
org/
org/reactivestreams/
org/ ... |
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/layer/ |
| D | mod.rs | 1238 S: Subscriber, in boxed()
1526 S: Subscriber, in layer_is_none()
1542 pub(crate) fn subscriber_is_none<S>(subscriber: &S) -> bool in subscriber_is_none()
|
| D | tests.rs | 45 fn assert_subscriber(_s: impl Subscriber) {} in assert_subscriber()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-core/src/ |
| D | subscriber.rs | 83 pub trait Subscriber: 'static { trait
504 impl dyn Subscriber { implementation
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/eventbus/outside/ |
| H A D | BaseSubscriberFinderTest.java | 27 static class Subscriber { class in BaseSubscriberFinderTest
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/eventbus/outside/ |
| H A D | BaseSubscriberFinderTest.java | 27 static class Subscriber { class in BaseSubscriberFinderTest
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | Flow.java | 218 public static interface Subscriber<T> { interface in Flow
|
| /aosp_15_r20/libcore/ojluni/src/main/java/java/util/concurrent/ |
| H A D | Flow.java | 218 public static interface Subscriber<T> { interface in Flow
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/19/libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | Flow.java | 218 public static interface Subscriber<T> { interface in Flow
|
| /aosp_15_r20/external/googleapis/google/pubsub/v1/ |
| H A D | pubsub.proto | 528 service Subscriber { service
545 rpc CreateSubscription(Subscription) returns (Subscription) {
|
| /aosp_15_r20/packages/services/Car/car-lib/src/android/car/telemetry/ |
| D | telemetry.proto | 195 message Subscriber { message
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/filter/layer_filters/ |
| D | mod.rs | 1283 pub(crate) fn subscriber_has_plf<S>(subscriber: &S) -> bool in subscriber_has_plf()
1294 S: Subscriber, in layer_has_plf()
|
| /aosp_15_r20/external/sdk-platform-java/test/integration/goldens/pubsub/src/com/google/cloud/pubsub/v1/ |
| H A D | gapic_metadata.json | 53 "Subscriber": { object
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/budgets/src/main/resources/codegen-resources/ |
| H A D | service-2.json | 984 "Subscriber":{ object
1126 "Subscriber":{ object
1851 "Subscriber":{ object
|
| /aosp_15_r20/out/soong/.intermediates/external/firebase-messaging/firebase-components-aar/android_common/aar/ |
| D | classes.jar | com/google/firebase/components/AbstractComponentContainer.class
AbstractComponentContainer.java
package com.google. ... |
| D | firebase-components-aar.jar | com/google/firebase/components/AbstractComponentContainer.class
AbstractComponentContainer.java
package com.google. ... |
| /aosp_15_r20/external/kotlinc/lib/ |
| HD | kotlinx-coroutines-core-jvm.jar | META-INF/
META-INF/MANIFEST.MF
kotlinx/
kotlinx/coroutines/
kotlinx/ ... |
| /aosp_15_r20/external/aws-sdk-java-v2/services/costexplorer/src/main/resources/codegen-resources/ |
| H A D | service-2.json | 4595 "Subscriber":{ object
|
| /aosp_15_r20/external/guice/lib/ |
| HD | guava-19.0.jar | META-INF/MANIFEST.MF
META-INF/
META-INF/maven/
META- ... |