Class ReactiveRandomProcessor

    • Constructor Detail

      • ReactiveRandomProcessor

        public ReactiveRandomProcessor()
    • Method Detail

      • processRequest

        public void processRequest​(HttpRequest request,
                                   EntityDetails entityDetails,
                                   ResponseChannel responseChannel,
                                   HttpContext context,
                                   org.reactivestreams.Publisher<java.nio.ByteBuffer> requestBody,
                                   Callback<org.reactivestreams.Publisher<java.nio.ByteBuffer>> responseBodyCallback)
                            throws HttpException,
                                   java.io.IOException
        Description copied from interface: ReactiveRequestProcessor
        Processes the actual HTTP request. The handler can choose to send response messages immediately inside the call or asynchronously at some later point.
        Specified by:
        processRequest in interface ReactiveRequestProcessor
        Parameters:
        request - the actual request.
        entityDetails - the request entity details or null if the request does not enclose an entity.
        responseChannel - the response channel.
        context - the actual execution context.
        requestBody - a reactive stream representing the request body.
        responseBodyCallback - a callback to invoke with the response body, if any.
        Throws:
        HttpException
        java.io.IOException