/*
 * Copyright (c) 2011-2017 Contributors to the Eclipse Foundation
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License 2.0 which is available at
 * http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
 * which is available at https://www.apache.org/licenses/LICENSE-2.0.
 *
 * SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
 */

package io.vertx.core.http;

import io.vertx.codegen.annotations.*;
import io.vertx.core.AsyncResult;
import io.vertx.core.Handler;
import io.vertx.core.MultiMap;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.streams.WriteStream;

Represents a server-side HTTP response.

An instance of this is created and associated to every instance of HttpServerRequest that.

It allows the developer to control the HTTP response that is sent back to the client for a particular HTTP request.

It contains methods that allow HTTP headers and trailers to be set, and for a body to be written out to the response.

It also allows files to be streamed by the kernel directly from disk to the outgoing HTTP connection, bypassing user space altogether (where supported by the underlying operating system). This is a very efficient way of serving files from the server since buffers do not have to be read one by one from the file and written to the outgoing socket.

It implements WriteStream so it can be used with Pump to pump data with flow control.

Author:Tim Fox
/** * Represents a server-side HTTP response. * <p> * An instance of this is created and associated to every instance of * {@link HttpServerRequest} that. * <p> * It allows the developer to control the HTTP response that is sent back to the * client for a particular HTTP request. * <p> * It contains methods that allow HTTP headers and trailers to be set, and for a body to be written out to the response. * <p> * It also allows files to be streamed by the kernel directly from disk to the * outgoing HTTP connection, bypassing user space altogether (where supported by * the underlying operating system). This is a very efficient way of * serving files from the server since buffers do not have to be read one by one * from the file and written to the outgoing socket. * <p> * It implements {@link io.vertx.core.streams.WriteStream} so it can be used with * {@link io.vertx.core.streams.Pump} to pump data with flow control. * * @author <a href="http://tfox.org">Tim Fox</a> */
@VertxGen public interface HttpServerResponse extends WriteStream<Buffer> { @Override HttpServerResponse exceptionHandler(Handler<Throwable> handler); @Override HttpServerResponse write(Buffer data);
Same as write(Buffer) but with an handler called when the operation completes
/** * Same as {@link #write(Buffer)} but with an {@code handler} called when the operation completes */
@Fluent HttpServerResponse write(Buffer data, Handler<AsyncResult<Void>> handler); @Override HttpServerResponse setWriteQueueMaxSize(int maxSize); @Override HttpServerResponse drainHandler(Handler<Void> handler);
Returns:the HTTP status code of the response. The default is 200 representing OK.
/** * @return the HTTP status code of the response. The default is {@code 200} representing {@code OK}. */
int getStatusCode();
Set the status code. If the status message hasn't been explicitly set, a default status message corresponding to the code will be looked-up and used.
Returns:a reference to this, so the API can be used fluently
/** * Set the status code. If the status message hasn't been explicitly set, a default status message corresponding * to the code will be looked-up and used. * * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse setStatusCode(int statusCode);
Returns:the HTTP status message of the response. If this is not specified a default value will be used depending on what setStatusCode has been set to.
/** * @return the HTTP status message of the response. If this is not specified a default value will be used depending on what * {@link #setStatusCode} has been set to. */
String getStatusMessage();
Set the status message
Returns:a reference to this, so the API can be used fluently
/** * Set the status message * * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse setStatusMessage(String statusMessage);
If chunked is true, this response will use HTTP chunked encoding, and each call to write to the body will correspond to a new HTTP chunk sent on the wire.

If chunked encoding is used the HTTP header Transfer-Encoding with a value of Chunked will be automatically inserted in the response.

If chunked is false, this response will not use HTTP chunked encoding, and therefore the total size of any data that is written in the respone body must be set in the Content-Length header before any data is written out.

An HTTP chunked response is typically used when you do not know the total size of the request body up front.

Returns:a reference to this, so the API can be used fluently
/** * If {@code chunked} is {@code true}, this response will use HTTP chunked encoding, and each call to write to the body * will correspond to a new HTTP chunk sent on the wire. * <p> * If chunked encoding is used the HTTP header {@code Transfer-Encoding} with a value of {@code Chunked} will be * automatically inserted in the response. * <p> * If {@code chunked} is {@code false}, this response will not use HTTP chunked encoding, and therefore the total size * of any data that is written in the respone body must be set in the {@code Content-Length} header <b>before</b> any * data is written out. * <p> * An HTTP chunked response is typically used when you do not know the total size of the request body up front. * * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse setChunked(boolean chunked);
Returns:is the response chunked?
/** * @return is the response chunked? */
boolean isChunked();
Returns:The HTTP headers
/** * @return The HTTP headers */
@CacheReturn MultiMap headers();
Put an HTTP header
Params:
  • name – the header name
  • value – the header value.
Returns:a reference to this, so the API can be used fluently
/** * Put an HTTP header * * @param name the header name * @param value the header value. * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse putHeader(String name, String value);
Like putHeader(String, String) but using CharSequence
/** * Like {@link #putHeader(String, String)} but using CharSequence */
@GenIgnore(GenIgnore.PERMITTED_TYPE) @Fluent HttpServerResponse putHeader(CharSequence name, CharSequence value);
Like putHeader(String, String) but providing multiple values via a String Iterable
/** * Like {@link #putHeader(String, String)} but providing multiple values via a String Iterable */
@GenIgnore(GenIgnore.PERMITTED_TYPE) @Fluent HttpServerResponse putHeader(String name, Iterable<String> values);
Like putHeader(String, Iterable<String>) but with CharSequence Iterable
/** * Like {@link #putHeader(String, Iterable)} but with CharSequence Iterable */
@GenIgnore(GenIgnore.PERMITTED_TYPE) @Fluent HttpServerResponse putHeader(CharSequence name, Iterable<CharSequence> values);
Returns:The HTTP trailers
/** * @return The HTTP trailers */
@CacheReturn MultiMap trailers();
Put an HTTP trailer
Params:
  • name – the trailer name
  • value – the trailer value
Returns:a reference to this, so the API can be used fluently
/** * Put an HTTP trailer * * @param name the trailer name * @param value the trailer value * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse putTrailer(String name, String value);
Like putTrailer(String, String) but using CharSequence
/** * Like {@link #putTrailer(String, String)} but using CharSequence */
@GenIgnore(GenIgnore.PERMITTED_TYPE) @Fluent HttpServerResponse putTrailer(CharSequence name, CharSequence value);
Like putTrailer(String, String) but providing multiple values via a String Iterable
/** * Like {@link #putTrailer(String, String)} but providing multiple values via a String Iterable */
@GenIgnore(GenIgnore.PERMITTED_TYPE) @Fluent HttpServerResponse putTrailer(String name, Iterable<String> values);
Like putTrailer(String, Iterable<String>) but with CharSequence Iterable
/** * Like {@link #putTrailer(String, Iterable)} but with CharSequence Iterable */
@GenIgnore(GenIgnore.PERMITTED_TYPE) @Fluent HttpServerResponse putTrailer(CharSequence name, Iterable<CharSequence> value);
Set a close handler for the response, this is called when the underlying connection is closed and the response was still using the connection.

For HTTP/1.x it is called when the connection is closed before end() is called, therefore it is not guaranteed to be called.

For HTTP/2 it is called when the related stream is closed, and therefore it will be always be called.

Params:
  • handler – the handler
Returns:a reference to this, so the API can be used fluently
/** * Set a close handler for the response, this is called when the underlying connection is closed and the response * was still using the connection. * <p> * For HTTP/1.x it is called when the connection is closed before {@code end()} is called, therefore it is not * guaranteed to be called. * <p> * For HTTP/2 it is called when the related stream is closed, and therefore it will be always be called. * * @param handler the handler * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse closeHandler(@Nullable Handler<Void> handler);
Set an end handler for the response. This will be called when the response is disposed to allow consistent cleanup of the response.
Params:
  • handler – the handler
Returns:a reference to this, so the API can be used fluently
/** * Set an end handler for the response. This will be called when the response is disposed to allow consistent cleanup * of the response. * * @param handler the handler * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse endHandler(@Nullable Handler<Void> handler);
Write a String to the response body, encoded using the encoding enc.
Params:
  • chunk – the string to write
  • enc – the encoding to use
Returns:a reference to this, so the API can be used fluently
/** * Write a {@link String} to the response body, encoded using the encoding {@code enc}. * * @param chunk the string to write * @param enc the encoding to use * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse write(String chunk, String enc);
Same as write(String, String) but with an handler called when the operation completes
/** * Same as {@link #write(String, String)} but with an {@code handler} called when the operation completes */
@Fluent HttpServerResponse write(String chunk, String enc, Handler<AsyncResult<Void>> handler);
Write a String to the response body, encoded in UTF-8.
Params:
  • chunk – the string to write
Returns:a reference to this, so the API can be used fluently
/** * Write a {@link String} to the response body, encoded in UTF-8. * * @param chunk the string to write * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse write(String chunk);
Same as write(String) but with an handler called when the operation completes
/** * Same as {@link #write(String)} but with an {@code handler} called when the operation completes */
@Fluent HttpServerResponse write(String chunk, Handler<AsyncResult<Void>> handler);
Used to write an interim 100 Continue response to signify that the client should send the rest of the request. Must only be used if the request contains an "Expect:100-Continue" header
Returns:a reference to this, so the API can be used fluently
/** * Used to write an interim 100 Continue response to signify that the client should send the rest of the request. * Must only be used if the request contains an "Expect:100-Continue" header * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse writeContinue();
Same as end(Buffer) but writes a String in UTF-8 encoding before ending the response.
Params:
  • chunk – the string to write before ending the response
/** * Same as {@link #end(Buffer)} but writes a String in UTF-8 encoding before ending the response. * * @param chunk the string to write before ending the response */
void end(String chunk);
Same as end(String) but with an handler called when the operation completes
/** * Same as {@link #end(String)} but with an {@code handler} called when the operation completes */
void end(String chunk, Handler<AsyncResult<Void>> handler);
Same as end(Buffer) but writes a String with the specified encoding before ending the response.
Params:
  • chunk – the string to write before ending the response
  • enc – the encoding to use
/** * Same as {@link #end(Buffer)} but writes a String with the specified encoding before ending the response. * * @param chunk the string to write before ending the response * @param enc the encoding to use */
void end(String chunk, String enc);
Same as end(String, String) but with an handler called when the operation completes
/** * Same as {@link #end(String, String)} but with an {@code handler} called when the operation completes */
void end(String chunk, String enc, Handler<AsyncResult<Void>> handler);
Same as end() but writes some data to the response body before ending. If the response is not chunked and no other data has been written then the @code{Content-Length} header will be automatically set.
Params:
  • chunk – the buffer to write before ending the response
/** * Same as {@link #end()} but writes some data to the response body before ending. If the response is not chunked and * no other data has been written then the @code{Content-Length} header will be automatically set. * * @param chunk the buffer to write before ending the response */
@Override void end(Buffer chunk);
Same as end(Buffer) but with an handler called when the operation completes
/** * Same as {@link #end(Buffer)} but with an {@code handler} called when the operation completes */
@Override void end(Buffer chunk, Handler<AsyncResult<Void>> handler);
Ends the response. If no data has been written to the response body, the actual response won't get written until this method gets called.

Once the response has ended, it cannot be used any more.

/** * Ends the response. If no data has been written to the response body, * the actual response won't get written until this method gets called. * <p> * Once the response has ended, it cannot be used any more. */
@Override void end();
Same as sendFile(String, long) using offset @code{0} which means starting from the beginning of the file.
Params:
  • filename – path to the file to serve
Returns:a reference to this, so the API can be used fluently
/** * Same as {@link #sendFile(String, long)} using offset @code{0} which means starting from the beginning of the file. * * @param filename path to the file to serve * @return a reference to this, so the API can be used fluently */
@Fluent default HttpServerResponse sendFile(String filename) { return sendFile(filename, 0); }
Same as sendFile(String, long, long) using length @code{Long.MAX_VALUE} which means until the end of the file.
Params:
  • filename – path to the file to serve
  • offset – offset to start serving from
Returns:a reference to this, so the API can be used fluently
/** * Same as {@link #sendFile(String, long, long)} using length @code{Long.MAX_VALUE} which means until the end of the * file. * * @param filename path to the file to serve * @param offset offset to start serving from * @return a reference to this, so the API can be used fluently */
@Fluent default HttpServerResponse sendFile(String filename, long offset) { return sendFile(filename, offset, Long.MAX_VALUE); }
Ask the OS to stream a file as specified by filename directly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system. This is a very efficient way to serve files.

The actual serve is asynchronous and may not complete until some time after this method has returned.

Params:
  • filename – path to the file to serve
  • offset – offset to start serving from
  • length – the number of bytes to send
Returns:a reference to this, so the API can be used fluently
/** * Ask the OS to stream a file as specified by {@code filename} directly * from disk to the outgoing connection, bypassing userspace altogether * (where supported by the underlying operating system. * This is a very efficient way to serve files.<p> * The actual serve is asynchronous and may not complete until some time after this method has returned. * * @param filename path to the file to serve * @param offset offset to start serving from * @param length the number of bytes to send * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse sendFile(String filename, long offset, long length);
Like sendFile(String) but providing a handler which will be notified once the file has been completely written to the wire.
Params:
  • filename – path to the file to serve
  • resultHandler – handler that will be called on completion
Returns:a reference to this, so the API can be used fluently
/** * Like {@link #sendFile(String)} but providing a handler which will be notified once the file has been completely * written to the wire. * * @param filename path to the file to serve * @param resultHandler handler that will be called on completion * @return a reference to this, so the API can be used fluently */
@Fluent default HttpServerResponse sendFile(String filename, Handler<AsyncResult<Void>> resultHandler) { return sendFile(filename, 0, resultHandler); }
Like sendFile(String, long) but providing a handler which will be notified once the file has been completely written to the wire.
Params:
  • filename – path to the file to serve
  • offset – the offset to serve from
  • resultHandler – handler that will be called on completion
Returns:a reference to this, so the API can be used fluently
/** * Like {@link #sendFile(String, long)} but providing a handler which will be notified once the file has been completely * written to the wire. * * @param filename path to the file to serve * @param offset the offset to serve from * @param resultHandler handler that will be called on completion * @return a reference to this, so the API can be used fluently */
@Fluent default HttpServerResponse sendFile(String filename, long offset, Handler<AsyncResult<Void>> resultHandler) { return sendFile(filename, offset, Long.MAX_VALUE, resultHandler); }
Like sendFile(String, long, long) but providing a handler which will be notified once the file has been completely written to the wire.
Params:
  • filename – path to the file to serve
  • offset – the offset to serve from
  • length – the length to serve to
  • resultHandler – handler that will be called on completion
Returns:a reference to this, so the API can be used fluently
/** * Like {@link #sendFile(String, long, long)} but providing a handler which will be notified once the file has been * completely written to the wire. * * @param filename path to the file to serve * @param offset the offset to serve from * @param length the length to serve to * @param resultHandler handler that will be called on completion * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse sendFile(String filename, long offset, long length, Handler<AsyncResult<Void>> resultHandler);
Close the underlying TCP connection corresponding to the request.
/** * Close the underlying TCP connection corresponding to the request. */
void close();
Returns:has the response already ended?
/** * @return has the response already ended? */
boolean ended();
Returns:has the underlying TCP connection corresponding to the request already been closed?
/** * @return has the underlying TCP connection corresponding to the request already been closed? */
boolean closed();
Returns:have the headers for the response already been written?
/** * @return have the headers for the response already been written? */
boolean headWritten();
Provide a handler that will be called just before the headers are written to the wire.

This provides a hook allowing you to add any more headers or do any more operations before this occurs.

Params:
  • handler – the handler
Returns:a reference to this, so the API can be used fluently
/** * Provide a handler that will be called just before the headers are written to the wire.<p> * This provides a hook allowing you to add any more headers or do any more operations before this occurs. * * @param handler the handler * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse headersEndHandler(@Nullable Handler<Void> handler);
Provides a handler that will be called after the last part of the body is written to the wire. The handler is called asynchronously of when the response has been received by the client. This provides a hook allowing you to do more operations once the request has been sent over the wire such as resource cleanup.
Params:
  • handler – the handler
Returns:a reference to this, so the API can be used fluently
/** * Provides a handler that will be called after the last part of the body is written to the wire. * The handler is called asynchronously of when the response has been received by the client. * This provides a hook allowing you to do more operations once the request has been sent over the wire * such as resource cleanup. * * @param handler the handler * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse bodyEndHandler(@Nullable Handler<Void> handler);
Returns:the total number of bytes written for the body of the response.
/** * @return the total number of bytes written for the body of the response. */
long bytesWritten();
Returns:the id of the stream of this response, -1 for HTTP/1.x
/** * @return the id of the stream of this response, {@literal -1} for HTTP/1.x */
int streamId(); /** * Like {@link #push(HttpMethod, String, String, MultiMap, Handler)} with no headers. */ @Fluent HttpServerResponse push(HttpMethod method, String host, String path, Handler<AsyncResult<HttpServerResponse>> handler); /** * Like {@link #push(HttpMethod, String, String, MultiMap, Handler)} with the host copied from the current request. */ @Fluent HttpServerResponse push(HttpMethod method, String path, MultiMap headers, Handler<AsyncResult<HttpServerResponse>> handler); /** * Like {@link #push(HttpMethod, String, String, MultiMap, Handler)} with the host copied from the current request. */ @Fluent HttpServerResponse push(HttpMethod method, String path, Handler<AsyncResult<HttpServerResponse>> handler);
Push a response to the client.

The handler will be notified with a success when the push can be sent and with a failure when the client has disabled push or reset the push before it has been sent.

The handler may be queued if the client has reduced the maximum number of streams the server can push concurrently.

Push can be sent only for peer initiated streams and if the response is not ended.
Params:
  • method – the method of the promised request
  • host – the host of the promised request
  • path – the path of the promised request
  • headers – the headers of the promised request
  • handler – the handler notified when the response can be written
Returns:a reference to this, so the API can be used fluently
/** * Push a response to the client.<p/> * * The {@code handler} will be notified with a <i>success</i> when the push can be sent and with * a <i>failure</i> when the client has disabled push or reset the push before it has been sent.<p/> * * The {@code handler} may be queued if the client has reduced the maximum number of streams the server can push * concurrently.<p/> * * Push can be sent only for peer initiated streams and if the response is not ended. * * @param method the method of the promised request * @param host the host of the promised request * @param path the path of the promised request * @param headers the headers of the promised request * @param handler the handler notified when the response can be written * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse push(HttpMethod method, String host, String path, MultiMap headers, Handler<AsyncResult<HttpServerResponse>> handler);
Reset this HTTP/2 stream with the error code 0.
/** * Reset this HTTP/2 stream with the error code {@code 0}. */
default void reset() { reset(0L); }
Reset this HTTP/2 stream with the error code.
Params:
  • code – the error code
/** * Reset this HTTP/2 stream with the error {@code code}. * * @param code the error code */
void reset(long code);
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.

The frame is sent immediatly and is not subject to flow control.

Params:
  • type – the 8-bit frame type
  • flags – the 8-bit frame flags
  • payload – the frame payload
Returns:a reference to this, so the API can be used fluently
/** * Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.<p> * * The frame is sent immediatly and is not subject to flow control. * * @param type the 8-bit frame type * @param flags the 8-bit frame flags * @param payload the frame payload * @return a reference to this, so the API can be used fluently */
@Fluent HttpServerResponse writeCustomFrame(int type, int flags, Buffer payload);
Params:
  • frame – the frame to write
/** * Like {@link #writeCustomFrame(int, int, Buffer)} but with an {@link HttpFrame}. * * @param frame the frame to write */
@Fluent default HttpServerResponse writeCustomFrame(HttpFrame frame) { return writeCustomFrame(frame.type(), frame.flags(), frame.payload()); }
Sets the priority of the associated stream

This is not implemented for HTTP/1.x.
Params:
  • streamPriority – the priority for this request's stream
/** * Sets the priority of the associated stream * <p/> * This is not implemented for HTTP/1.x. * * @param streamPriority the priority for this request's stream */
@Fluent default HttpServerResponse setStreamPriority(StreamPriority streamPriority) { return this; } }