Class DataSubscriptionServiceGrpc.DataSubscriptionServiceFutureStub (0.2.0)
public static final class DataSubscriptionServiceGrpc.DataSubscriptionServiceFutureStub extends AbstractFutureStub<DataSubscriptionServiceGrpc.DataSubscriptionServiceFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service
DataSubscriptionService.
Data Subscription Service that allows clients (e.g., Fitbit 3P
applications, internal Fitbit Services) to manage their subscriber endpoints.
This service provides CRUD APIs for subscribers,
and also offers functionalities for subscriber verification and statistics.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
DataSubscriptionServiceGrpc.DataSubscriptionServiceFutureStub
Inherited Members
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.getCallOptions()
io.grpc.stub.AbstractStub.getChannel()
io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)
io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)
io.grpc.stub.AbstractStub.withCompression(java.lang.String)
io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)
io.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration)
io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)
io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)
io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)
io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)
io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)
io.grpc.stub.AbstractStub.withOnReadyThreshold(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
build(Channel channel, CallOptions callOptions)
protected DataSubscriptionServiceGrpc.DataSubscriptionServiceFutureStub build(Channel channel, CallOptions callOptions)
| Parameters |
| Name |
Description |
channel |
io.grpc.Channel
|
callOptions |
io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
createSubscriber(CreateSubscriberRequest request)
public ListenableFuture<Operation> createSubscriber(CreateSubscriberRequest request)
Registers a new subscriber endpoint to receive notifications.
A subscriber represents an application or service that wishes to receive
data change notifications for users who have granted consent.
Endpoint Verification:
For a subscriber to be successfully created, the provided endpoint_uri
must be a valid HTTPS endpoint and must pass an automated verification
check. The backend will send two HTTP POST requests to the endpoint_uri:
- Verification with Authorization:
- Headers: Includes
Content-Type: application/json and
Authorization (with the exact value from
CreateSubscriberPayload.endpoint_authorization.secret).
- Body:
{"type": "verification"}
- Expected Response: HTTP
201 Created.
- Verification without Authorization:
- Headers: Includes
Content-Type: application/json. The
Authorization header is OMITTED.
- Body:
{"type": "verification"}
- Expected Response: HTTP
401 Unauthorized or 403 Forbidden.
Both tests must pass for the subscriber creation to succeed. If
verification fails, the operation will not be completed and an error will
be returned. This process ensures the endpoint is reachable and correctly
validates the Authorization header.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
createSubscription(CreateSubscriptionRequest request)
public ListenableFuture<Subscription> createSubscription(CreateSubscriptionRequest request)
Creates a subscription for a specific user to a specific subscriber.
This method requires the subscriber to have a SubscriptionCreatePolicy
set to MANUAL for the given data types.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
|
deleteSubscriber(DeleteSubscriberRequest request)
public ListenableFuture<Operation> deleteSubscriber(DeleteSubscriberRequest request)
Deletes a subscriber registration. This will stop all notifications
to the subscriber's endpoint.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
deleteSubscription(DeleteSubscriptionRequest request)
public ListenableFuture<Empty> deleteSubscription(DeleteSubscriptionRequest request)
Deletes a specific user subscription, stopping notifications for this
user to this subscriber.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Empty> |
|
listSubscribers(ListSubscribersRequest request)
public ListenableFuture<ListSubscribersResponse> listSubscribers(ListSubscribersRequest request)
Lists all subscribers registered within the owned Google Cloud Project.
listSubscriptions(ListSubscriptionsRequest request)
public ListenableFuture<ListSubscriptionsResponse> listSubscriptions(ListSubscriptionsRequest request)
Lists all active subscriptions for a given subscriber. This can be
filtered, for example, by user or data type.
updateSubscriber(UpdateSubscriberRequest request)
public ListenableFuture<Operation> updateSubscriber(UpdateSubscriberRequest request)
Updates the configuration of an existing subscriber, such as the
endpoint URI or the data types it's interested in.
Endpoint Verification:
If the endpoint_uri or endpoint_authorization field is included in the
update_mask, the backend will re-verify the endpoint. The verification
process is the same as described in CreateSubscriber:
- Verification with Authorization: POST to the new or existing
endpoint_uri with the new or existing Authorization secret. Expects
HTTP 201 Created.
- Verification without Authorization: POST to the
endpoint_uri
without the Authorization header. Expects HTTP 401 Unauthorized or
403 Forbidden.
Both tests must pass using the potentially updated values for the
subscriber update to succeed. If verification fails, the update will not
be applied, and an error will be returned.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
updateSubscription(UpdateSubscriptionRequest request)
public ListenableFuture<Subscription> updateSubscription(UpdateSubscriptionRequest request)
Updates the data types for an existing user subscription.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
|
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2026-06-18 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2026-06-18 UTC."],[],[]]