Класс HttpResponse.BodySubscribers

Переданная функция finisher применяется после вызова onComplete заданного подписчика. Функция finisher вызывается с заданным подписчиком и возвращает значение, которое устанавливается в качестве тела ответа.

Переданная функция finisher применяется после вызова onComplete заданного подписчика. Функция finisher вызывается с заданным подписчиком и возвращает значение, которое устанавливается в качестве тела ответа.

HttpResponse с этим подписчиком доступен после чтения всего ответа.

HttpResponse с этим подписчиком доступен после чтения всего ответа.

HttpResponse с этим подписчиком доступен после чтения всего ответа.

В случае использования поставщика файловой системы по умолчанию, проверки разрешений менеджера безопасности выполняются в этом методе, когда BodySubscriber создаётся. В противном случае, проверки разрешений могут выполняться асинхронно по отношению к контексту вызывающего кода в момент доступа к файлу. Необходимо позаботиться о том, чтобы BodySubscriber не был предоставлен небезопасным кодом.

Эквивалентно: ofFile(file, CREATE, WRITE)

В случае использования поставщика файловой системы по умолчанию, проверки разрешений менеджера безопасности выполняются в этом методе, когда BodySubscriber создаётся. В противном случае, проверки разрешений могут выполняться асинхронно по отношению к контексту вызывающего кода в момент доступа к файлу. Необходимо позаботиться о том, чтобы BodySubscriber не был предоставлен небезопасным кодом.

HttpResponse с этим подписчиком доступен после чтения всего ответа.

HttpResponse, использующий этого подписчика, доступен сразу после чтения заголовков ответа, без ожидания обработки всего тела. Тело ответа можно затем прочитать напрямую из InputStream.

HttpResponse, использующий этого подписчика, доступен сразу после чтения заголовков ответа, без ожидания обработки всего тела. Тело ответа можно затем прочитать напрямую из Stream.

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

Издатель, возвращаемый методом body, может быть подписан только один раз. Первый подписчик получит байты ответа при успешном подписывании, или подписка будет отменена в противном случае. Если будут попытки подписки, последующие подписчики будут немедленно подписаны с пустой подпиской, и их метод onError будет вызван с IllegalStateException.

Возвращаемый подписчик делегирует свой метод getBody() подписчику вниз по потоку.

Функция отображения выполняется с помощью исполнителя клиента executor и поэтому может быть использована для отображения любого типа тела ответа, включая блокирующие InputStream. Однако выполнение любой блокирующей операции в функции отображения несёт риск блокировки потока исполнителя на неизвестное время (по крайней мере, до завершения блокирующей операции), что может привести к недостатку доступных потоков для исполнителя. Поэтому, в случае, когда отображение в требуемый тип может заблокировать (например, при чтении из InputStream), предпочтительнее отобразить на Supplier нужного типа и отложить блокирующую операцию до вызова Supplier::get потоком вызывающей стороны, как показано в следующем примере, который использует известный парсер JSON для преобразования InputStream в любой аннотированный Java-тип.

Например:

 public static <W> BodySubscriber<Supplier<W>> asJSON(Class<W> targetType) {
   BodySubscriber<InputStream> upstream = BodySubscribers.ofInputStream();

   BodySubscriber<Supplier<W>> downstream = BodySubscribers.mapping(
         upstream,
         (InputStream is) -> () -> {
             try (InputStream stream = is) {
                 ObjectMapper objectMapper = new ObjectMapper();
                 return objectMapper.readValue(stream, targetType);
             } catch (IOException e) {
                 throw new UncheckedIOException(e);
             }
         });
  return downstream;
}