Class StreamsGrpc.StreamsStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<StreamsGrpc.StreamsStub>
com.eventstore.dbclient.proto.streams.StreamsGrpc.StreamsStub
- Enclosing class:
- StreamsGrpc
public static final class StreamsGrpc.StreamsStub
extends io.grpc.stub.AbstractAsyncStub<StreamsGrpc.StreamsStub>
A stub to allow clients to do asynchronous rpc calls to service Streams.
-
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 TypeMethodDescriptionio.grpc.stub.StreamObserver<StreamsOuterClass.AppendReq>append(io.grpc.stub.StreamObserver<StreamsOuterClass.AppendResp> responseObserver) io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendReq>batchAppend(io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendResp> responseObserver) protected StreamsGrpc.StreamsStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) voiddelete(StreamsOuterClass.DeleteReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.DeleteResp> responseObserver) voidread(StreamsOuterClass.ReadReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.ReadResp> responseObserver) voidtombstone(StreamsOuterClass.TombstoneReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.TombstoneResp> responseObserver) Methods inherited from class io.grpc.stub.AbstractAsyncStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
- Specified by:
buildin classio.grpc.stub.AbstractStub<StreamsGrpc.StreamsStub>
-
read
public void read(StreamsOuterClass.ReadReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.ReadResp> responseObserver) -
append
public io.grpc.stub.StreamObserver<StreamsOuterClass.AppendReq> append(io.grpc.stub.StreamObserver<StreamsOuterClass.AppendResp> responseObserver) -
delete
public void delete(StreamsOuterClass.DeleteReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.DeleteResp> responseObserver) -
tombstone
public void tombstone(StreamsOuterClass.TombstoneReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.TombstoneResp> responseObserver) -
batchAppend
public io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendReq> batchAppend(io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendResp> responseObserver)
-