Package io.servicetalk.grpc.api

Interface GrpcRoutes.RequestStreamingRoute<Req,Resp>

Type Parameters:

Req - Type of request.

Resp - Type of response.

All Superinterfaces:

AsyncCloseable

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.RequestStreamingRoute<Req,Resp>
extends AsyncCloseable

An asynchronous gRPC route with request streaming.

Method Summary

Modifier and Type	Method	Description
default Completable	closeAsync()	Used to close/shutdown a resource.
Single<Resp>	handle(GrpcServiceContext ctx, Publisher<Req> request)	Handles the passed GrpcRoutes.RequestStreamingRoute.
static <Req,Resp> GrpcRoutes.RequestStreamingRoute<Req,Resp>	wrap(GrpcRoutes.RequestStreamingRoute<Req,Resp> rawRoute, AsyncCloseable closeable)	Convenience method to wrap a raw GrpcRoutes.RequestStreamingRoute instance with a passed detached close implementation of AsyncCloseable.

Methods inherited from interface io.servicetalk.concurrent.api.AsyncCloseable

closeAsyncGracefully

Method Detail

handle

Single<Resp> handle(GrpcServiceContext ctx,
                    Publisher<Req> request)

Handles the passed GrpcRoutes.RequestStreamingRoute.

Parameters:

ctx - GrpcServiceContext for this call.

request - Publisher of GrpcRoutes.RequestStreamingRoute to handle.

Returns:

Single containing the response.

closeAsync

default Completable closeAsync()

Description copied from interface: AsyncCloseable

Used to close/shutdown a resource.

Specified by:

closeAsync in interface AsyncCloseable

Returns:

A Completable that is notified once the close is complete.

wrap

static <Req,Resp> GrpcRoutes.RequestStreamingRoute<Req,Resp> wrap(GrpcRoutes.RequestStreamingRoute<Req,Resp> rawRoute,
                                                                              AsyncCloseable closeable)

Convenience method to wrap a raw GrpcRoutes.RequestStreamingRoute instance with a passed detached close implementation of AsyncCloseable.

Type Parameters:

Req - Type of request.

Resp - Type of response.

Parameters:

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

closeable - AsyncCloseable implementation for the passed rawRoute.

Returns:

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