Class ClientStreamingMethodHandlerSupplier.ClientStreaming<ReqT,​RespT>

  • Type Parameters:
    ReqT - the request type
    RespT - the response type
    All Implemented Interfaces:
    io.grpc.stub.ServerCalls.BidiStreamingMethod<ReqT,​RespT>, io.grpc.stub.ServerCalls.ClientStreamingMethod<ReqT,​RespT>, io.grpc.stub.ServerCalls.ServerStreamingMethod<ReqT,​RespT>, io.grpc.stub.ServerCalls.UnaryMethod<ReqT,​RespT>, MethodHandler<ReqT,​RespT>
    Enclosing class:
    ClientStreamingMethodHandlerSupplier

    public static class ClientStreamingMethodHandlerSupplier.ClientStreaming<ReqT,​RespT>
    extends ClientStreamingMethodHandlerSupplier.AbstractClientStreamingHandler<ReqT,​RespT>
    A client streaming MethodHandler that calls a standard client streaming method handler method of the form.
         StreamObserver<ReqT> invoke(StreamObserver<RespT> observer)
     
    • Method Detail

      • invoke

        protected io.grpc.stub.StreamObserver<ReqT> invoke​(Method method,
                                                           Object instance,
                                                           io.grpc.stub.StreamObserver<RespT> observer)
                                                    throws InvocationTargetException,
                                                           IllegalAccessException
        Description copied from class: io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler
        Invoke the actual client streaming or bi-directional gRPC method handler.
        Specified by:
        invoke in class io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler<ReqT,​RespT>
        Parameters:
        method - the Method to invoke
        instance - the service instance to invoke the method on
        observer - the method response observer
        Returns:
        the StreamObserver to receive requests from the client
        Throws:
        InvocationTargetException - if an error occurs invoking the method
        IllegalAccessException - if the method cannot be accessed