Package com.bytedesk.core.proto

Class SimpleGrpc.MethodHandlers<Req,Resp>

java.lang.Object

com.bytedesk.core.proto.SimpleGrpc.MethodHandlers<Req,Resp>

All Implemented Interfaces:

io.grpc.stub.ServerCalls.BidiStreamingMethod<Req,Resp>, io.grpc.stub.ServerCalls.ClientStreamingMethod<Req,Resp>, io.grpc.stub.ServerCalls.ServerStreamingMethod<Req,Resp>, io.grpc.stub.ServerCalls.UnaryMethod<Req,Resp>

Enclosing class:

SimpleGrpc

private static final class SimpleGrpc.MethodHandlers<Req,Resp>
extends Object
implements io.grpc.stub.ServerCalls.UnaryMethod<Req,Resp>, io.grpc.stub.ServerCalls.ServerStreamingMethod<Req,Resp>, io.grpc.stub.ServerCalls.ClientStreamingMethod<Req,Resp>, io.grpc.stub.ServerCalls.BidiStreamingMethod<Req,Resp>

Field Summary

Fields

Modifier and Type	Field	Description
private final int	methodId
private final SimpleGrpc.AsyncService	serviceImpl

Constructor Summary

Constructors

Constructor	Description
MethodHandlers(SimpleGrpc.AsyncService serviceImpl, int methodId)

Method Summary

Modifier and Type	Method	Description
io.grpc.stub.StreamObserver<Req>	invoke(io.grpc.stub.StreamObserver<Resp> responseObserver)
void	invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

serviceImpl

private final SimpleGrpc.AsyncService serviceImpl

methodId

private final int methodId

Constructor Details

MethodHandlers

MethodHandlers(SimpleGrpc.AsyncService serviceImpl,
 int methodId)

Method Details

invoke

public void invoke(Req request,
 io.grpc.stub.StreamObserver<Resp> responseObserver)

Specified by:

invoke in interface io.grpc.stub.ServerCalls.ServerStreamingMethod<Req,Resp>

Specified by:

invoke in interface io.grpc.stub.ServerCalls.UnaryMethod<Req,Resp>

invoke

public io.grpc.stub.StreamObserver<Req> invoke(io.grpc.stub.StreamObserver<Resp> responseObserver)

Specified by:

invoke in interface io.grpc.stub.ServerCalls.BidiStreamingMethod<Req,Resp>

Specified by:

invoke in interface io.grpc.stub.ServerCalls.ClientStreamingMethod<Req,Resp>