io.servicetalk.grpc.api

Interface GrpcRoutes.BlockingRequestStreamingRoute<Req,Resp>

Type Parameters:

Req - Type of request.

Resp - Type of response.

All Superinterfaces:

java.lang.AutoCloseable, GracefulAutoCloseable

Enclosing class:

GrpcRoutes<Service extends GrpcService>

protected static interface GrpcRoutes.BlockingRequestStreamingRoute<Req,Resp>
extends GracefulAutoCloseable

A blocking gRPC route with request streaming.

Method Summary

Modifier and Type	Method and Description
default void	close()
Resp	handle(GrpcServiceContext ctx, BlockingIterable<Req> request) Handles the passed Req.

Methods inherited from interface io.servicetalk.concurrent.GracefulAutoCloseable

closeGracefully

Method Detail

handle

Resp handle(GrpcServiceContext ctx,
            BlockingIterable<Req> request)
     throws java.lang.Exception

Handles the passed Req.

Parameters:

ctx - GrpcServiceContext for this call.

request - BlockingIterable of Req to handle.

Returns:

The response.

Throws:

java.lang.Exception - If an exception occurs during request processing.

close

default void close()

Specified by:

close in interface java.lang.AutoCloseable