-
static <T,
R> com.hazelcast.jet.pipeline.ServiceFactory<?,? extends GrpcService<T,R>>
GrpcServices.bidirectionalStreamingService(com.hazelcast.function.SupplierEx<? extends io.grpc.ManagedChannelBuilder<?>> channelFn,
com.hazelcast.function.FunctionEx<? super io.grpc.ManagedChannel,? extends com.hazelcast.function.FunctionEx<io.grpc.stub.StreamObserver<R>,io.grpc.stub.StreamObserver<T>>> callStubFn)
static <T,
R> com.hazelcast.jet.pipeline.ServiceFactory<?,? extends GrpcService<T,R>>
GrpcServices.unaryService(com.hazelcast.function.SupplierEx<? extends io.grpc.ManagedChannelBuilder<?>> channelFn,
com.hazelcast.function.FunctionEx<? super io.grpc.ManagedChannel,? extends com.hazelcast.function.BiConsumerEx<T,io.grpc.stub.StreamObserver<R>>> callStubFn)