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

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

Уведомление о входящем push promise.

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

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

Если функция acceptor не будет успешно вызвана, push promise отклоняется. Функция acceptor будет выбрасывать IllegalStateException, если вызывается более одного раза.

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

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

Записи добавляются в заданную карту для каждого принятого push promise. Ключом записи является запрос push, а значением — CompletableFuture, который завершается ответом, соответствующим запросу push в качестве ключа. Запрос push отклоняется/отменяется, если в карте уже есть запись, ключ которой равен ему. Запрос push отклоняется/отменяется, если у него нет того же происхождения, что и у инициализирующего запроса.

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

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