Class ClientStreamingMethodHandlerSupplier.ClientStreamingStream<ReqT,RespT>

java.lang.Object
io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler<ReqT,RespT>
io.helidon.microprofile.grpc.core.ClientStreamingMethodHandlerSupplier.AbstractClientStreamingHandler<ReqT,RespT>
io.helidon.microprofile.grpc.core.ClientStreamingMethodHandlerSupplier.ClientStreamingStream<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.ClientStreamingStream<ReqT,RespT> extends ClientStreamingMethodHandlerSupplier.AbstractClientStreamingHandler<ReqT,RespT>
A client side only client streaming MethodHandler that streams requests from a stream.
     CompletionStage<RespT> invoke(Stream<ReqT> observer)
 
  • Method Details

    • clientOnly

      public boolean clientOnly()
      Description copied from interface: MethodHandler
      Determine whether this is a client side only handler.
      Returns:
      true if this handler can only be used on the client
    • 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
    • clientStreaming

      public Object clientStreaming(Object[] args, MethodHandler.ClientStreaming client)
      Description copied from interface: MethodHandler
      Handle a bi-directional client call.
      Parameters:
      args - the call arguments.
      client - the MethodHandler.ClientStreaming instance to forward the call to.
      Returns:
      the call result