com.eventstore.dbclient

Class GrpcUtils

java.lang.Object

com.eventstore.dbclient.GrpcUtils

public final class GrpcUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
GrpcUtils()

Method Summary

Modifier and Type	Method and Description
static <ReqT,RespT> io.grpc.stub.ClientResponseObserver<ReqT,RespT>	convertSingleResponse(java.util.concurrent.CompletableFuture<RespT> dest)
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)
static com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.StreamOptions	toStreamOptions(java.lang.String streamName, StreamRevision revision)

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcUtils

public GrpcUtils()

Method Detail

convertSingleResponse

public static <ReqT,RespT> io.grpc.stub.ClientResponseObserver<ReqT,RespT> convertSingleResponse(java.util.concurrent.CompletableFuture<RespT> dest)

convertSingleResponse

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)

toStreamOptions

public static com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.StreamOptions toStreamOptions(java.lang.String streamName,
                                                                                                                    StreamRevision revision)