Module io.helidon.microprofile.grpc.core

Package io.helidon.microprofile.grpc.core

Class BidirectionalMethodHandlerSupplier.AbstractServerStreamingHandler<ReqT,RespT>

java.lang.Object

io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler<ReqT,RespT>

io.helidon.microprofile.grpc.core.BidirectionalMethodHandlerSupplier.AbstractServerStreamingHandler<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:

BidirectionalMethodHandlerSupplier.BidiStreaming

Enclosing class:

BidirectionalMethodHandlerSupplier

public abstract static class BidirectionalMethodHandlerSupplier.AbstractServerStreamingHandler<ReqT,RespT>
extends io.helidon.microprofile.grpc.core.AbstractMethodHandlerSupplier.AbstractHandler<ReqT,RespT>

A base class for bi-directional 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 Detail

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