Module io.helidon.microprofile.grpc.core

Package io.helidon.microprofile.grpc.core

Class ServerStreamingMethodHandlerSupplier.AbstractServerStreamingHandler<ReqT,RespT>

java.lang.Object

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

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

ServerStreamingMethodHandlerSupplier.ServerStreaming, ServerStreamingMethodHandlerSupplier.ServerStreamingNoRequest, ServerStreamingMethodHandlerSupplier.StreamResponse, ServerStreamingMethodHandlerSupplier.StreamResponseNoRequest

Enclosing class:

ServerStreamingMethodHandlerSupplier

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

A base class for server 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 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.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 io.grpc.stub.StreamObserver<ReqT> invoke(Method method,
 Object instance,
 io.grpc.stub.StreamObserver<RespT> observer)

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