Package com.eventstore.dbclient.proto.streams

Interface StreamsGrpc.AsyncService

All Known Implementing Classes:

StreamsGrpc.StreamsImplBase

Enclosing class:

StreamsGrpc

public static interface StreamsGrpc.AsyncService

Method Summary

Modifier and Type	Method	Description
default io.grpc.stub.StreamObserver<StreamsOuterClass.AppendReq>	append(io.grpc.stub.StreamObserver<StreamsOuterClass.AppendResp> responseObserver)
default io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendReq>	batchAppend(io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendResp> responseObserver)
default void	delete(StreamsOuterClass.DeleteReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.DeleteResp> responseObserver)
default void	read(StreamsOuterClass.ReadReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.ReadResp> responseObserver)
default void	tombstone(StreamsOuterClass.TombstoneReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.TombstoneResp> responseObserver)

Method Details

read

default void read(StreamsOuterClass.ReadReq request,
 io.grpc.stub.StreamObserver<StreamsOuterClass.ReadResp> responseObserver)

append

default io.grpc.stub.StreamObserver<StreamsOuterClass.AppendReq> append(io.grpc.stub.StreamObserver<StreamsOuterClass.AppendResp> responseObserver)

delete

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

tombstone

default void tombstone(StreamsOuterClass.TombstoneReq request,
 io.grpc.stub.StreamObserver<StreamsOuterClass.TombstoneResp> responseObserver)

batchAppend

default io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendReq> batchAppend(io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendResp> responseObserver)