Examples of org.xlightweb.BodyForwarder

org.xlightweb.BodyForwarder

be called if request header is received (Default-InvokeOn is HEADER_RECEIVED) public void onRequest(IHttpExchange exchange) throws IOException { IHttpRequestHeader requestHeader = exchange.getRequest().getRequestHeader(); NonBlockingBodyDataSource requestBodyChannel = exchange.getRequest().getNonBlockingBody(); // forwards the request (header) BodyDataSink dataSink = httpClient.send(requestHeader); // defines the body forwarder BodyForwarder bodyForwarder = new BodyForwarder(requestBodyChannel, dataSink) { public void onData(NonBlockingBodyDataSource bodyDataSource, BodyDataSink bodyDataSink) throws BufferUnderflowException, IOException { int available = bodyDataSink.available(); ByteBuffer[] data = bodyDataSink.readByteBufferByLength(available); for (ByteBuffer byteBuffer : data) { ByteBuffer copy = byteBuffer.duplicate(); // ... } bodyDataSink.write(data); } }; // assign the body forwarder to the body data source requestBodyChannel.setDataHandler(bodyForwarder); } } @author grro@xlightweb.org

                header.setHeader("Connection", "close");
                
                BodyDataSink bodyDataSink = HttpServerConnection.this.sendResponseHeader(header, false);
                
                NonBlockingBodyDataSource bodyDataSource = response.getNonBlockingBody();
                BodyForwarder forwarder = new BodyForwarder(bodyDataSource, bodyDataSink);
                bodyDataSource.setDataHandler(forwarder);
                return;
              } 
              
              // http protocol version downgrade necessary?

Examples of org.xlightweb.BodyForwarder

Related Classes of org.xlightweb.BodyForwarder