Package com.eventstore.dbclient

Class GrpcUtils

  • public final class GrpcUtils
extends java.lang.Object

    • Constructor Summary

      Constructors 
      Constructor Description
      GrpcUtils()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method 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)