Интерфейс 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, если вызвана более одного раза.

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 в карте могут или не могут быть уже завершены на этом этапе.