Реактивный декодер GZIP

Question

Spring-core 5.2 имеет код c пакет с декодером, например StringDecoder, который поддерживает реактивное программирование. API получить Publisher<DataBuffer> и вернуть декодированный Flux<String>.

Я надеялся найти GzipDecoder, который получит Publisher<DataBuffer> или Publisher<ByteArray> gzip и вернет некомпрометированный Flux<ByteArray>, но я не нашел его.

единственная библиотека, которая, как мне кажется, соответствует моему требованию, это https://github.com/kptfh/gzip-reactive, но она очень незрелая

Кто-нибудь знаком со зрелым кодом?

Answer 1

Я обнаружил, что в приведенном выше проекте скопируйте код из org.eclipse.jetty.http.GZIPContentDecoder

я добавляю зависимость ниже (управляется весенней загрузкой)

    <dependency>
        <groupId>org.eclipse.jetty</groupId>
        <artifactId>jetty-http</artifactId>
    </dependency>

и используя метод декодирования в примере функции карты:

GZIPContentDecoder decoder = new GZIPContentDecoder(2048);
        return Flux.from(input).map(decoder::decode)
                .doFinally(signalType -> decoder.destroy());