io.grpc.stub

Class ServerCalls

java.lang.Object

io.grpc.stub.ServerCalls

public final class ServerCalls
extends Object

Utility functions for adapting ServerCallHandlers to application service implementation, meant to be used by the generated code.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ServerCalls.BidiStreamingMethod<ReqT,RespT> Adaptor to a bidirectional streaming method.
static interface	ServerCalls.ClientStreamingMethod<ReqT,RespT> Adaptor to a client streaming method.
static interface	ServerCalls.ServerStreamingMethod<ReqT,RespT> Adaptor to a server streaming method.
static interface	ServerCalls.UnaryMethod<ReqT,RespT> Adaptor to a unary call method.

Method Summary

Modifier and Type	Method and Description
static <ReqT,RespT> io.grpc.ServerCallHandler<ReqT,RespT>	asyncBidiStreamingCall(ServerCalls.BidiStreamingMethod<ReqT,RespT> method) Creates a ServerCallHandler for a bidi streaming method of the service.
static <ReqT,RespT> io.grpc.ServerCallHandler<ReqT,RespT>	asyncClientStreamingCall(ServerCalls.ClientStreamingMethod<ReqT,RespT> method) Creates a ServerCallHandler for a client streaming method of the service.
static <ReqT,RespT> io.grpc.ServerCallHandler<ReqT,RespT>	asyncServerStreamingCall(ServerCalls.ServerStreamingMethod<ReqT,RespT> method) Creates a ServerCallHandler for a server streaming method of the service.
static <ReqT,RespT> io.grpc.ServerCallHandler<ReqT,RespT>	asyncUnaryCall(ServerCalls.UnaryMethod<ReqT,RespT> method) Creates a ServerCallHandler for a unary call method of the service.
static <ReqT> StreamObserver<ReqT>	asyncUnimplementedStreamingCall(io.grpc.MethodDescriptor<?,?> methodDescriptor, StreamObserver<?> responseObserver) Sets unimplemented status for streaming call.
static void	asyncUnimplementedUnaryCall(io.grpc.MethodDescriptor<?,?> methodDescriptor, StreamObserver<?> responseObserver) Sets unimplemented status for method on given response stream for unary call.

Methods inherited from class java.lang.Object

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

Method Detail

asyncUnaryCall

public static <ReqT,RespT> io.grpc.ServerCallHandler<ReqT,RespT> asyncUnaryCall(ServerCalls.UnaryMethod<ReqT,RespT> method)

Creates a ServerCallHandler for a unary call method of the service.

Parameters:

method - an adaptor to the actual method on the service implementation.

asyncServerStreamingCall

public static <ReqT,RespT> io.grpc.ServerCallHandler<ReqT,RespT> asyncServerStreamingCall(ServerCalls.ServerStreamingMethod<ReqT,RespT> method)

Creates a ServerCallHandler for a server streaming method of the service.

Parameters:

method - an adaptor to the actual method on the service implementation.

asyncClientStreamingCall

public static <ReqT,RespT> io.grpc.ServerCallHandler<ReqT,RespT> asyncClientStreamingCall(ServerCalls.ClientStreamingMethod<ReqT,RespT> method)

Creates a ServerCallHandler for a client streaming method of the service.

Parameters:

method - an adaptor to the actual method on the service implementation.

asyncBidiStreamingCall

public static <ReqT,RespT> io.grpc.ServerCallHandler<ReqT,RespT> asyncBidiStreamingCall(ServerCalls.BidiStreamingMethod<ReqT,RespT> method)

Creates a ServerCallHandler for a bidi streaming method of the service.

Parameters:

method - an adaptor to the actual method on the service implementation.

asyncUnimplementedUnaryCall

public static void asyncUnimplementedUnaryCall(io.grpc.MethodDescriptor<?,?> methodDescriptor,
                                               StreamObserver<?> responseObserver)

Sets unimplemented status for method on given response stream for unary call.

Parameters:

methodDescriptor - of method for which error will be thrown.

responseObserver - on which error will be set.

asyncUnimplementedStreamingCall

public static <ReqT> StreamObserver<ReqT> asyncUnimplementedStreamingCall(io.grpc.MethodDescriptor<?,?> methodDescriptor,
                                                                          StreamObserver<?> responseObserver)

Sets unimplemented status for streaming call.

Parameters:

methodDescriptor - of method for which error will be thrown.

responseObserver - on which error will be set.