Class ClientStreamingMethodHandlerSupplier.AbstractClientStreamingHandler<ReqT,RespT>

java.lang.Object
io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler<ReqT,RespT>
io.helidon.microprofile.grpc.core.ClientStreamingMethodHandlerSupplier.AbstractClientStreamingHandler<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>
Direct Known Subclasses:
ClientStreamingMethodHandlerSupplier.ClientStreaming, ClientStreamingMethodHandlerSupplier.ClientStreamingIterable, ClientStreamingMethodHandlerSupplier.ClientStreamingStream, ClientStreamingMethodHandlerSupplier.FutureResponse
Enclosing class:
ClientStreamingMethodHandlerSupplier

public abstract static class ClientStreamingMethodHandlerSupplier.AbstractClientStreamingHandler<ReqT,RespT> extends io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler<ReqT,RespT>
A base class for client streaming MethodHandlers.
  • Method Details

    • invoke

      protected void invoke(Method method, Object instance, ReqT request, io.grpc.stub.StreamObserver<RespT> observer)
      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