Uses of Interface
com.hazelcast.jet.grpc.GrpcService

  • Uses of GrpcService in com.hazelcast.jet.grpc

    Methods in com.hazelcast.jet.grpc that return types with arguments of type GrpcService
    Modifier and Type
    Method
    Description
    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)
    Creates a ServiceFactory that calls out to a bidirectional streaming gRPC service.
    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)
    Creates a ServiceFactory that calls out to a unary gRPC service.