Интерфейс 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, содержащиеся в карте, к этому моменту могут быть как завершены, так и не завершены.