public final class GrpcUtils
extends java.lang.Object
| Constructor and Description |
|---|
GrpcUtils() |
| Modifier and Type | Method and Description |
|---|---|
static <ReqT,RespT> |
convertSingleResponse(java.util.concurrent.CompletableFuture<RespT> dest) |
static <ReqT,RespT,TargetT,ExceptionT extends java.lang.Throwable> |
convertSingleResponse(java.util.concurrent.CompletableFuture<TargetT> dest,
com.eventstore.dbclient.ThrowingFunction<RespT,TargetT,ExceptionT> converter) |
static com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.StreamOptions |
toStreamOptions(java.lang.String streamName,
StreamRevision revision) |
public static <ReqT,RespT> io.grpc.stub.ClientResponseObserver<ReqT,RespT> convertSingleResponse(java.util.concurrent.CompletableFuture<RespT> dest)
public static <ReqT,RespT,TargetT,ExceptionT extends java.lang.Throwable> io.grpc.stub.ClientResponseObserver<ReqT,RespT> convertSingleResponse(java.util.concurrent.CompletableFuture<TargetT> dest,
com.eventstore.dbclient.ThrowingFunction<RespT,TargetT,ExceptionT> converter)
public static com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.StreamOptions toStreamOptions(java.lang.String streamName,
StreamRevision revision)