Module io.helidon.microprofile.grpc.core

Package io.helidon.microprofile.grpc.core

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)
 

Nested Class Summary

Nested classes/interfaces inherited from interface io.helidon.grpc.core.MethodHandler

MethodHandler.BidirectionalClient, MethodHandler.ClientStreaming, MethodHandler.ServerStreamingClient, MethodHandler.UnaryClient

Method Summary

Modifier and Type	Method	Description
boolean	clientOnly()	Determine whether this is a client side only handler.
Object	clientStreaming(Object[] args, MethodHandler.ClientStreaming client)	Handle a bi-directional client call.
protected io.grpc.stub.StreamObserver<ReqT>	invoke(Method method, Object instance, io.grpc.stub.StreamObserver<RespT> observer)	Invoke the actual client streaming or bi-directional gRPC method handler.

Methods inherited from class io.helidon.microprofile.grpc.core.ClientStreamingMethodHandlerSupplier.AbstractClientStreamingHandler

invoke

Methods inherited from class io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler

getGenericResponseType, getRequestType, getResponseType, handleFuture, invoke, invoke, javaMethodName, methodName, setRequestType, setResponseType, type

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.helidon.grpc.core.MethodHandler

bidirectional, serverStreaming, unary

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