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,​TargetT>
      io.grpc.stub.ClientResponseObserver<ReqT,​RespT>
      convertSingleResponse​(java.util.concurrent.CompletableFuture<TargetT> dest, java.util.function.Function<RespT,​TargetT> 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,​TargetT> io.grpc.stub.ClientResponseObserver<ReqT,​RespT> convertSingleResponse​(java.util.concurrent.CompletableFuture<TargetT> dest,
                                                                                                                                   java.util.function.Function<RespT,​TargetT> converter)
      • toStreamOptions

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