Module io.helidon.microprofile.grpc.core

Package io.helidon.microprofile.grpc.core

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.

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
protected void	invoke(Method method, Object instance, ReqT request, io.grpc.stub.StreamObserver<RespT> observer)	Invoke the actual unary or server streaming gRPC method handler.

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

getGenericResponseType, getRequestType, getResponseType, handleFuture, invoke, 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, clientOnly, clientStreaming, serverStreaming, unary

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