Package com.eventstore.dbclient.proto.persistentsubscriptions

Class PersistentSubscriptionsGrpc.PersistentSubscriptionsStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<PersistentSubscriptionsGrpc.PersistentSubscriptionsStub>

com.eventstore.dbclient.proto.persistentsubscriptions.PersistentSubscriptionsGrpc.PersistentSubscriptionsStub

Enclosing class:

PersistentSubscriptionsGrpc

public static final class PersistentSubscriptionsGrpc.PersistentSubscriptionsStub
extends io.grpc.stub.AbstractAsyncStub<PersistentSubscriptionsGrpc.PersistentSubscriptionsStub>

A stub to allow clients to do asynchronous rpc calls to service PersistentSubscriptions.

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected PersistentSubscriptionsGrpc.PersistentSubscriptionsStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	create(Persistent.CreateReq request, io.grpc.stub.StreamObserver<Persistent.CreateResp> responseObserver)
void	delete(Persistent.DeleteReq request, io.grpc.stub.StreamObserver<Persistent.DeleteResp> responseObserver)
void	getInfo(Persistent.GetInfoReq request, io.grpc.stub.StreamObserver<Persistent.GetInfoResp> responseObserver)
void	list(Persistent.ListReq request, io.grpc.stub.StreamObserver<Persistent.ListResp> responseObserver)
io.grpc.stub.StreamObserver<Persistent.ReadReq>	read(io.grpc.stub.StreamObserver<Persistent.ReadResp> responseObserver)
void	replayParked(Persistent.ReplayParkedReq request, io.grpc.stub.StreamObserver<Persistent.ReplayParkedResp> responseObserver)
void	restartSubsystem(Shared.Empty request, io.grpc.stub.StreamObserver<Shared.Empty> responseObserver)
void	update(Persistent.UpdateReq request, io.grpc.stub.StreamObserver<Persistent.UpdateResp> responseObserver)

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

build

protected PersistentSubscriptionsGrpc.PersistentSubscriptionsStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<PersistentSubscriptionsGrpc.PersistentSubscriptionsStub>

create

public void create(Persistent.CreateReq request,
 io.grpc.stub.StreamObserver<Persistent.CreateResp> responseObserver)

update

public void update(Persistent.UpdateReq request,
 io.grpc.stub.StreamObserver<Persistent.UpdateResp> responseObserver)

delete

public void delete(Persistent.DeleteReq request,
 io.grpc.stub.StreamObserver<Persistent.DeleteResp> responseObserver)

read

public io.grpc.stub.StreamObserver<Persistent.ReadReq> read(io.grpc.stub.StreamObserver<Persistent.ReadResp> responseObserver)

getInfo

public void getInfo(Persistent.GetInfoReq request,
 io.grpc.stub.StreamObserver<Persistent.GetInfoResp> responseObserver)

replayParked

public void replayParked(Persistent.ReplayParkedReq request,
 io.grpc.stub.StreamObserver<Persistent.ReplayParkedResp> responseObserver)

list

public void list(Persistent.ListReq request,
 io.grpc.stub.StreamObserver<Persistent.ListResp> responseObserver)

restartSubsystem

public void restartSubsystem(Shared.Empty request,
 io.grpc.stub.StreamObserver<Shared.Empty> responseObserver)