Package io.servicetalk.grpc.api

Interface GrpcRoutes.BlockingStreamingRoute<Req,Resp>

Type Parameters:

Req - Type of request.

Resp - Type of response.

All Superinterfaces:

java.lang.AutoCloseable, GracefulAutoCloseable

Enclosing class:

GrpcRoutes<Service extends GrpcService>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
protected static interface GrpcRoutes.BlockingStreamingRoute<Req,Resp>
extends GracefulAutoCloseable

A blocking gRPC route with bi-directional streaming.

Method Summary

Modifier and Type	Method	Description
default void	close()
void	handle(GrpcServiceContext ctx, BlockingIterable<Req> request, GrpcPayloadWriter<Resp> responseWriter)	Handles the passed GrpcRoutes.BlockingStreamingRoute.
static <Req,Resp> GrpcRoutes.BlockingStreamingRoute<Req,Resp>	wrap(GrpcRoutes.BlockingStreamingRoute<Req,Resp> rawRoute, GracefulAutoCloseable closeable)	Convenience method to wrap a raw GrpcRoutes.BlockingStreamingRoute instance with a passed detached close implementation of GracefulAutoCloseable.

Methods inherited from interface io.servicetalk.concurrent.GracefulAutoCloseable

closeGracefully

Method Detail

handle

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

Handles the passed GrpcRoutes.BlockingStreamingRoute.

Parameters:

ctx - GrpcServiceContext for this call.

request - BlockingIterable of GrpcRoutes.BlockingStreamingRoute to handle.

responseWriter - GrpcPayloadWriter to write the response.

Throws:

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

close

default void close()
            throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

wrap

static <Req,Resp> GrpcRoutes.BlockingStreamingRoute<Req,Resp> wrap(GrpcRoutes.BlockingStreamingRoute<Req,Resp> rawRoute,
                                                                               GracefulAutoCloseable closeable)

Convenience method to wrap a raw GrpcRoutes.BlockingStreamingRoute instance with a passed detached close implementation of GracefulAutoCloseable.

Type Parameters:

Req - Type of request.

Resp - Type of response.

Parameters:

rawRoute - GrpcRoutes.BlockingStreamingRoute instance that has a detached close implementation.

closeable - GracefulAutoCloseable implementation for the passed rawRoute.

Returns:

A new GrpcRoutes.BlockingStreamingRoute that attaches the passed closeable to the passed rawRoute.