Интерфейс HttpResponse.PushPromiseHandler<T>

void applyPushPromise(HttpRequest initiatingRequest, HttpRequest pushPromiseRequest, Function<HttpResponse.BodyHandler<T>, CompletableFuture<HttpResponse<T>>> acceptor)

Уведомление о входящем push-обещании.

Этот метод вызывается для каждого полученного push-обещания до момента полного получения тела ответа на инициирующий запрос, отправленный клиентом.

Push-обещание принимается вызовом указанной функции acceptor. Функции acceptor необходимо передать ненулевой объект BodyHandler, который будет использоваться для обработки тела ответа на обещание. Функция-приемник возвращает объект CompletableFuture, выполнение которого завершается ответом на обещание.

Если функция acceptor не была успешно вызвана, push-обещание отклоняется. При повторном вызове функция acceptor выбрасывает исключение IllegalStateException.

Этот метод вызывается для всех push-обещаний HTTP/2, а также по умолчанию для первого push-обещания HTTP/3. Если переопределен метод applyPushPromise(HttpRequest, HttpRequest, PushId, Function), этот метод напрямую не вызывается для push-обещаний HTTP/3.

default void applyPushPromise(HttpRequest initiatingRequest, HttpRequest pushPromiseRequest, HttpResponse.PushPromiseHandler.PushId pushid, Function<HttpResponse.BodyHandler<T>, CompletableFuture<HttpResponse<T>>> acceptor)

Уведомление о первом входящем push-обещании HTTP/3. О последующих обещаниях того же ресурса (с тем же PushId) уведомляет метод notifyAdditionalPromise(HttpRequest, PushId).

Этот метод вызывается для каждого полученного push-обещания до момента полного получения тела ответа на инициирующий запрос, отправленный клиентом.

Push-обещание принимается вызовом указанной функции acceptor. Функции acceptor необходимо передать ненулевой объект BodyHandler, который будет использоваться для обработки тела ответа на обещание. Функция-приемник возвращает объект CompletableFuture, выполнение которого завершается ответом на обещание.

Если функция acceptor не была успешно вызвана, push-обещание отклоняется. При повторном вызове функция acceptor выбрасывает исключение IllegalStateException.

default void notifyAdditionalPromise(HttpRequest initiatingRequest, HttpResponse.PushPromiseHandler.PushId pushid)

Вызывается для каждого дополнительного push-обещания HTTP/3. Объект pushid связывает обещание с исходным обещанным HttpRequest и HttpResponse. Дополнительные обещания обычно возникают в результате разных запросов, инициированных клиентом.

static <T> HttpResponse.PushPromiseHandler<T> of(Function<HttpRequest, HttpResponse.BodyHandler<T>> pushPromiseHandler, ConcurrentMap<HttpRequest, CompletableFuture<HttpResponse<T>>> pushPromisesMap)

Возвращает обработчик push-обещаний, который накапливает push-обещания и ответы на них в указанной карте.

Для каждого принятого push-обещания в указанную карту добавляется запись. Ключом записи является push-запрос, а значением — объект CompletableFuture, выполнение которого завершается ответом, соответствующим push-запросу, указанному в ключе. Push-запрос отклоняется / отменяется, если в карте уже есть запись с равным ему ключом (равным). Push-запрос отклоняется / отменяется, если его источник отличается от источника инициирующего запроса.

Записи добавляются в указанную карту как можно скорее после получения и принятия push-обещания. Благодаря этому код, использующий такую карту, например, в качестве кэша, может определить, было ли отправлено сервером push-обещание, и избежать, возможно, ненужных запросов.

Доставка ответа на push-обещание не согласуется с доставкой ответа на инициирующий запрос, отправленный клиентом. Однако после полного получения тела ответа на инициирующий запрос, отправленный клиентом, карта гарантированно будет заполнена полностью, то есть новые записи добавляться уже не будут. Отдельные объекты CompletableFutures в карте к этому моменту могут быть завершены, а могут и не быть.