Class ReactiveEchoProcessor

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void processRequest​(HttpRequest request, EntityDetails entityDetails, ResponseChannel responseChannel, HttpContext context, org.reactivestreams.Publisher<java.nio.ByteBuffer> requestBody, Callback<org.reactivestreams.Publisher<java.nio.ByteBuffer>> responseBodyFuture)
      Processes the actual HTTP request.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ReactiveEchoProcessor

        public ReactiveEchoProcessor()
    • 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>> responseBodyFuture)
                            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.
        responseBodyFuture - a callback to invoke with the response body, if any.
        Throws:
        HttpException
        java.io.IOException