Class ServerStreamingMethodHandlerSupplier.ServerStreaming<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:
    ServerStreamingMethodHandlerSupplier

    public static class ServerStreamingMethodHandlerSupplier.ServerStreaming<ReqT,​RespT>
    extends ServerStreamingMethodHandlerSupplier.AbstractServerStreamingHandler<ReqT,​RespT>
    A server streaming MethodHandler that calls a standard server streaming method handler method of the form.
         void invoke(ReqT request, StreamObserver<RespT> observer)
     
    • Method Detail

      • invoke

        protected void invoke​(Method method,
                              Object instance,
                              ReqT request,
                              io.grpc.stub.StreamObserver<RespT> observer)
                       throws InvocationTargetException,
                              IllegalAccessException
        Description copied from class: io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler
        Invoke the actual unary or server streaming 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
        request - the method request
        observer - the method response observer
        Throws:
        InvocationTargetException - if an error occurs invoking the method
        IllegalAccessException - if the method cannot be accessed