public static class SubscriberGrpc.SubscriberFutureStub extends io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberFutureStub> implements SubscriberGrpc.SubscriberFutureClient
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<Empty> |
acknowledge(AcknowledgeRequest request) |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
createSubscription(Subscription request) |
com.google.common.util.concurrent.ListenableFuture<Empty> |
deleteSubscription(DeleteSubscriptionRequest request) |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
getSubscription(GetSubscriptionRequest request) |
com.google.common.util.concurrent.ListenableFuture<ListSubscriptionsResponse> |
listSubscriptions(ListSubscriptionsRequest request) |
com.google.common.util.concurrent.ListenableFuture<Empty> |
modifyAckDeadline(ModifyAckDeadlineRequest request) |
com.google.common.util.concurrent.ListenableFuture<Empty> |
modifyPushConfig(ModifyPushConfigRequest request) |
com.google.common.util.concurrent.ListenableFuture<PullResponse> |
pull(PullRequest request) |
public com.google.common.util.concurrent.ListenableFuture<Subscription> createSubscription(Subscription request)
createSubscription
in interface SubscriberGrpc.SubscriberFutureClient
public com.google.common.util.concurrent.ListenableFuture<Subscription> getSubscription(GetSubscriptionRequest request)
getSubscription
in interface SubscriberGrpc.SubscriberFutureClient
public com.google.common.util.concurrent.ListenableFuture<ListSubscriptionsResponse> listSubscriptions(ListSubscriptionsRequest request)
listSubscriptions
in interface SubscriberGrpc.SubscriberFutureClient
public com.google.common.util.concurrent.ListenableFuture<Empty> deleteSubscription(DeleteSubscriptionRequest request)
deleteSubscription
in interface SubscriberGrpc.SubscriberFutureClient
public com.google.common.util.concurrent.ListenableFuture<Empty> modifyAckDeadline(ModifyAckDeadlineRequest request)
modifyAckDeadline
in interface SubscriberGrpc.SubscriberFutureClient
public com.google.common.util.concurrent.ListenableFuture<Empty> acknowledge(AcknowledgeRequest request)
acknowledge
in interface SubscriberGrpc.SubscriberFutureClient
public com.google.common.util.concurrent.ListenableFuture<PullResponse> pull(PullRequest request)
pull
in interface SubscriberGrpc.SubscriberFutureClient
public com.google.common.util.concurrent.ListenableFuture<Empty> modifyPushConfig(ModifyPushConfigRequest request)
modifyPushConfig
in interface SubscriberGrpc.SubscriberFutureClient