Module io.helidon.microprofile.grpc.core

Package io.helidon.microprofile.grpc.core

Class BidirectionalMethodHandlerSupplier.BidiStreaming<ReqT,RespT>

java.lang.Object

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

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

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

BidirectionalMethodHandlerSupplier

public static class BidirectionalMethodHandlerSupplier.BidiStreaming<ReqT,RespT>
extends BidirectionalMethodHandlerSupplier.AbstractServerStreamingHandler<ReqT,RespT>

A bi-directional streaming MethodHandler that calls a standard bi-directional streaming method handler method of the form.

     StreamObserver<ReqT> invoke(StreamObserver<RespT> 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
Object	bidirectional(Object[] args, MethodHandler.BidirectionalClient 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.BidirectionalMethodHandlerSupplier.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

clientOnly, clientStreaming, serverStreaming, unary

Method Details

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

bidirectional

public Object bidirectional(Object[] args,
 MethodHandler.BidirectionalClient client)

Description copied from interface: MethodHandler

Handle a bi-directional client call.

Parameters:

args - the call arguments.

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

Returns:

the call result