Module io.helidon.microprofile.grpc.core

Package io.helidon.microprofile.grpc.core

Class ServerStreamingMethodHandlerSupplier.StreamResponseNoRequest<ReqT,RespT>

java.lang.Object

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

io.helidon.microprofile.grpc.core.ServerStreamingMethodHandlerSupplier.AbstractServerStreamingHandler<ReqT,RespT>

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

ServerStreamingMethodHandlerSupplier

public static class ServerStreamingMethodHandlerSupplier.StreamResponseNoRequest<ReqT,RespT>
extends ServerStreamingMethodHandlerSupplier.AbstractServerStreamingHandler<ReqT,RespT>

A server streaming MethodHandler that calls a calls a server streaming method handler method of the form.

     Stream<RespT> invoke()
 

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.
Object	serverStreaming(Object[] args, MethodHandler.ServerStreamingClient client)	Handle a bi-directional client call.

Methods inherited from class io.helidon.microprofile.grpc.core.ServerStreamingMethodHandlerSupplier.AbstractServerStreamingHandler

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, clientOnly, clientStreaming, unary

Method Details

invoke

protected void invoke(Method method,
 Object instance,
 ReqT request,
 io.grpc.stub.StreamObserver<RespT> observer)
               throws InvocationTargetException,
IllegalAccessException

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

Throws:

InvocationTargetException - if an error occurs invoking the method

IllegalAccessException - if the method cannot be accessed

serverStreaming

public Object serverStreaming(Object[] args,
 MethodHandler.ServerStreamingClient client)

Description copied from interface: MethodHandler

Handle a bi-directional client call.

Parameters:

args - the call arguments.

client - the MethodHandler.ServerStreamingClient instance to forward the call to.

Returns:

the call result