io.servicetalk.grpc.api

Interface GrpcRoutes.StreamingRoute<Req,Resp>

Type Parameters:

Req - Type of request.

Resp - Type of response.

All Superinterfaces:

AsyncCloseable

Enclosing class:

GrpcRoutes<Service extends GrpcService>

protected static interface GrpcRoutes.StreamingRoute<Req,Resp>
extends AsyncCloseable

An asynchronous gRPC route with bi-directional streaming.

Method Summary

Modifier and Type	Method and Description
default Completable	closeAsync() Used to close/shutdown a resource.
Publisher<Resp>	handle(GrpcServiceContext ctx, Publisher<Req> request) Handles the passed Req.

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

closeAsyncGracefully

Method Detail

handle

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

Handles the passed Req.

Parameters:

ctx - GrpcServiceContext for this call.

request - Publisher of Req 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 CompletableSource that is notified once the close is complete.