@FunctionalInterface public interface StreamingHttpService extends AsyncCloseable
Modifier and Type | Method and Description |
---|---|
default Completable |
closeAsync()
Closes this
StreamingHttpService asynchronously. |
Single<StreamingHttpResponse> |
handle(HttpServiceContext ctx,
StreamingHttpRequest request,
StreamingHttpResponseFactory responseFactory)
Handles a single HTTP request.
|
closeAsyncGracefully
Single<StreamingHttpResponse> handle(HttpServiceContext ctx, StreamingHttpRequest request, StreamingHttpResponseFactory responseFactory)
ctx
- Context of the service.request
- to handle.responseFactory
- used to create StreamingHttpResponse
objects.Single
of HTTP response.default Completable closeAsync()
StreamingHttpService
asynchronously.closeAsync
in interface AsyncCloseable
Completable
that when subscribed will close this StreamingHttpService
.