Класс HttpResponse.BodyHandlers

public static HttpResponse.BodyHandler<Void> fromSubscriber(Flow.Subscriber<? super List<ByteBuffer>> subscriber)

Примечание API:

Этот метод может использоваться в качестве адаптера между BodySubscriber и Flow.Subscriber.

Например:

TextSubscriber subscriber = new TextSubscriber();
HttpResponse<Void> response = client.sendAsync(request,
    BodyHandlers.fromSubscriber(subscriber)).join();
System.out.println(response.statusCode());

Параметры:

subscriber - подписчик

Возвращает:

обработчик тела ответа

public static <S extends Flow.Subscriber<? super List<ByteBuffer>>, T> HttpResponse.BodyHandler<T> fromSubscriber(S subscriber, Function<? super S, ? extends T> finisher)

Примечание API:

Этот метод может использоваться в качестве адаптера между BodySubscriber и Flow.Subscriber.

Например:

TextSubscriber subscriber = ...;  // accumulates bytes and transforms them into a String
HttpResponse<String> response = client.sendAsync(request,
    BodyHandlers.fromSubscriber(subscriber, TextSubscriber::getTextResult)).join();
String text = response.body();

Параметры типа:

S - тип подписчика

T - тип тела ответа

Параметры:

subscriber - подписчик

finisher - функция, которая будет применена после завершения подписчика

Возвращает:

обработчик тела ответа

public static HttpResponse.BodyHandler<Void> fromLineSubscriber(Flow.Subscriber<? super String> subscriber)

Примечание API:

Этот метод может использоваться в качестве адаптера между BodySubscriber и текстовым Flow.Subscriber, который анализирует текст построчно.

Например:

// A PrintSubscriber that implements Flow.Subscriber<String>
// and print lines received by onNext() on System.out
PrintSubscriber subscriber = new PrintSubscriber(System.out);
client.sendAsync(request, BodyHandlers.fromLineSubscriber(subscriber))
    .thenApply(HttpResponse::statusCode)
    .thenAccept((status) -> {
        if (status != 200) {
            System.err.printf("ERROR: %d status received%n", status);
        }
    });

Параметры:

subscriber - подписчик

Возвращает:

обработчик тела ответа

public static <S extends Flow.Subscriber<? super String>, T> HttpResponse.BodyHandler<T> fromLineSubscriber(S subscriber, Function<? super S, ? extends T> finisher, String lineSeparator)

Примечание API:

Этот метод может использоваться в качестве адаптера между BodySubscriber и текстовым Flow.Subscriber, который анализирует текст построчно.

Например:

// A LineParserSubscriber that implements Flow.Subscriber<String>
// and accumulates lines that match a particular pattern
Pattern pattern = ...;
LineParserSubscriber subscriber = new LineParserSubscriber(pattern);
HttpResponse<List<String>> response = client.send(request,
    BodyHandlers.fromLineSubscriber(subscriber, s -> s.getMatchingLines(), "\n"));
if (response.statusCode() != 200) {
    System.err.printf("ERROR: %d status received%n", response.statusCode());
}

Параметры типа:

S - тип подписчика

T - тип тела ответа

Параметры:

subscriber - подписчик

finisher - функция, которая будет применена после завершения подписчика

lineSeparator - необязательный разделитель строк: может быть null, в этом случае строки будут разделяться по способу BufferedReader.readLine().

Возвращает:

обработчик тела ответа

Исключения:

IllegalArgumentException - если заданный lineSeparator пустая строка

public static HttpResponse.BodyHandler<Void> discarding()

Возвращает:

обработчик тела ответа

public static <U> HttpResponse.BodyHandler<U> replacing(U value)

Параметры типа:

U - тип тела ответа

Параметры:

value - значение U для возврата в качестве тела, может быть null

Возвращает:

обработчик тела ответа

public static HttpResponse.BodyHandler<String> ofString(Charset charset)

Параметры:

charset - набор символов для преобразования тела

Возвращает:

обработчик тела ответа

public static HttpResponse.BodyHandler<Path> ofFile(Path file, OpenOption... openOptions)

Параметры:

file - файл для хранения тела

openOptions - любые параметры для открытия/создания файла

Возвращает:

обработчик тела ответа

Исключения:

IllegalArgumentException - если задан неверный набор параметров открытия

public static HttpResponse.BodyHandler<Path> ofFile(Path file)

Параметры:

file - файл для хранения тела

Возвращает:

обработчик тела ответа

public static HttpResponse.BodyHandler<Path> ofFileDownload(Path directory, OpenOption... openOptions)

Параметры:

directory - каталог для хранения файла

openOptions - опции открытия, используемые при открытии файла

Возвращает:

обработчик тела ответа

Исключения:

IllegalArgumentException - если заданный путь не существует, не соответствует стандартной файловой системе, не является каталогом, не является доступным для записи или если указан недопустимый набор опций открытия

public static HttpResponse.BodyHandler<InputStream> ofInputStream()

Примечание API:

См. HttpResponse.BodySubscribers.ofInputStream() для получения дополнительной информации.

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

Возвращает:

обработчик потокового тела ответа

public static HttpResponse.BodyHandler<Stream<String>> ofLines()

Примечание API:

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

Возвращает:

обработчик потокового тела ответа

public static HttpResponse.BodyHandler<Void> ofByteArrayConsumer(Consumer<Optional<byte[]>> consumer)

Примечание API:

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

Параметры:

consumer - потребитель для приема тела ответа

Возвращает:

обработчик тела ответа

public static HttpResponse.BodyHandler<byte[]> ofByteArray()

Возвращает:

обработчик тела ответа

public static HttpResponse.BodyHandler<String> ofString()

Возвращает:

обработчик тела ответа

public static HttpResponse.BodyHandler<Flow.Publisher<List<ByteBuffer>>> ofPublisher()

Примечание API:

См. HttpResponse.BodySubscribers.ofPublisher() для получения дополнительной информации.

Для обеспечения надлежащего освобождения всех ресурсов, связанных с соответствующим обменом, вызывающий метод должен подписаться на издателя и следовать правилам, описанным в HttpResponse.BodySubscribers.ofPublisher()

Возвращает:

обработчик тела ответа с публикацией

public static <T> HttpResponse.BodyHandler<T> buffering(HttpResponse.BodyHandler<T> downstreamHandler, int bufferSize)

Параметры типа:

T - тип тела ответа

Параметры:

downstreamHandler - обработчик по нисходящей цепи

bufferSize - параметр размера буфера, передаваемый в BodySubscribers.buffering

Возвращает:

обработчик тела

Исключения:

IllegalArgumentException - если bufferSize <= 0