Class PersistentSubscriptionsGrpc.PersistentSubscriptionsFutureStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractFutureStub<PersistentSubscriptionsGrpc.PersistentSubscriptionsFutureStub>
-
- com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc.PersistentSubscriptionsFutureStub
-
- Enclosing class:
- PersistentSubscriptionsGrpc
public static final class PersistentSubscriptionsGrpc.PersistentSubscriptionsFutureStub extends io.grpc.stub.AbstractFutureStub<PersistentSubscriptionsGrpc.PersistentSubscriptionsFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service PersistentSubscriptions.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected PersistentSubscriptionsGrpc.PersistentSubscriptionsFutureStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<Persistent.CreateResp>
create(Persistent.CreateReq request)
com.google.common.util.concurrent.ListenableFuture<Persistent.DeleteResp>
delete(Persistent.DeleteReq request)
com.google.common.util.concurrent.ListenableFuture<Persistent.GetInfoResp>
getInfo(Persistent.GetInfoReq request)
com.google.common.util.concurrent.ListenableFuture<Persistent.ListResp>
list(Persistent.ListReq request)
com.google.common.util.concurrent.ListenableFuture<Persistent.ReplayParkedResp>
replayParked(Persistent.ReplayParkedReq request)
com.google.common.util.concurrent.ListenableFuture<Shared.Empty>
restartSubsystem(Shared.Empty request)
com.google.common.util.concurrent.ListenableFuture<Persistent.UpdateResp>
update(Persistent.UpdateReq request)
-
-
-
Method Detail
-
build
protected PersistentSubscriptionsGrpc.PersistentSubscriptionsFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
build
in classio.grpc.stub.AbstractStub<PersistentSubscriptionsGrpc.PersistentSubscriptionsFutureStub>
-
create
public com.google.common.util.concurrent.ListenableFuture<Persistent.CreateResp> create(Persistent.CreateReq request)
-
update
public com.google.common.util.concurrent.ListenableFuture<Persistent.UpdateResp> update(Persistent.UpdateReq request)
-
delete
public com.google.common.util.concurrent.ListenableFuture<Persistent.DeleteResp> delete(Persistent.DeleteReq request)
-
getInfo
public com.google.common.util.concurrent.ListenableFuture<Persistent.GetInfoResp> getInfo(Persistent.GetInfoReq request)
-
replayParked
public com.google.common.util.concurrent.ListenableFuture<Persistent.ReplayParkedResp> replayParked(Persistent.ReplayParkedReq request)
-
list
public com.google.common.util.concurrent.ListenableFuture<Persistent.ListResp> list(Persistent.ListReq request)
-
restartSubsystem
public com.google.common.util.concurrent.ListenableFuture<Shared.Empty> restartSubsystem(Shared.Empty request)
-
-