Package org.apache.hc.client5.http.async.methods

Class DeflatingGzipEntityProducer

java.lang.Object

org.apache.hc.client5.http.async.methods.DeflatingGzipEntityProducer

All Implemented Interfaces:

org.apache.hc.core5.http.EntityDetails, org.apache.hc.core5.http.nio.AsyncDataProducer, org.apache.hc.core5.http.nio.AsyncEntityProducer, org.apache.hc.core5.http.nio.ResourceHolder

public final class DeflatingGzipEntityProducer
extends java.lang.Object
implements org.apache.hc.core5.http.nio.AsyncEntityProducer

Streams an AsyncEntityProducer through raw DEFLATE and wraps the result in a valid GZIP container.

Memory usage is bounded (8 KiB buffers) and back-pressure from the I/O reactor is honoured.

Since:

5.6

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	DeflatingGzipEntityProducer.InnerChannel

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.zip.CRC32	crc
private java.util.zip.Deflater	deflater
private org.apache.hc.core5.http.nio.AsyncEntityProducer	delegate
private boolean	finished
private boolean	headerSent
private byte[]	in
private static int	IN_BUF
private static int	OUT_BUF
private java.nio.ByteBuffer	outBuf
private java.util.concurrent.atomic.AtomicBoolean	released
private long	uncompressed

Constructor Summary

Constructors

Constructor	Description
DeflatingGzipEntityProducer(org.apache.hc.core5.http.nio.AsyncEntityProducer delegate)

Method Summary

Modifier and Type	Method	Description
int	available()
private void	deflateToOut()
void	failed(java.lang.Exception cause)
private void	flushOut(org.apache.hc.core5.http.nio.DataStreamChannel chan)
java.lang.String	getContentEncoding()
long	getContentLength()
java.lang.String	getContentType()
java.util.Set<java.lang.String>	getTrailerNames()
boolean	isChunked()
boolean	isRepeatable()
void	produce(org.apache.hc.core5.http.nio.DataStreamChannel chan)
void	releaseResources()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

IN_BUF

private static final int IN_BUF

See Also:

Constant Field Values

OUT_BUF

private static final int OUT_BUF

See Also:

Constant Field Values

delegate

private final org.apache.hc.core5.http.nio.AsyncEntityProducer delegate

crc

private final java.util.zip.CRC32 crc

deflater

private final java.util.zip.Deflater deflater

in

private final byte[] in

outBuf

private final java.nio.ByteBuffer outBuf

headerSent

private boolean headerSent

finished

private boolean finished

uncompressed

private long uncompressed

released

private final java.util.concurrent.atomic.AtomicBoolean released

Constructor Detail

DeflatingGzipEntityProducer

public DeflatingGzipEntityProducer(org.apache.hc.core5.http.nio.AsyncEntityProducer delegate)

Method Detail

isRepeatable

public boolean isRepeatable()

Specified by:

isRepeatable in interface org.apache.hc.core5.http.nio.AsyncEntityProducer

getContentLength

public long getContentLength()

Specified by:

getContentLength in interface org.apache.hc.core5.http.EntityDetails

getContentType

public java.lang.String getContentType()

Specified by:

getContentType in interface org.apache.hc.core5.http.EntityDetails

getContentEncoding

public java.lang.String getContentEncoding()

Specified by:

getContentEncoding in interface org.apache.hc.core5.http.EntityDetails

isChunked

public boolean isChunked()

Specified by:

isChunked in interface org.apache.hc.core5.http.EntityDetails

getTrailerNames

public java.util.Set<java.lang.String> getTrailerNames()

Specified by:

getTrailerNames in interface org.apache.hc.core5.http.EntityDetails

available

public int available()

Specified by:

available in interface org.apache.hc.core5.http.nio.AsyncDataProducer

produce

public void produce(org.apache.hc.core5.http.nio.DataStreamChannel chan)
             throws java.io.IOException

Specified by:

produce in interface org.apache.hc.core5.http.nio.AsyncDataProducer

Throws:

java.io.IOException

deflateToOut

private void deflateToOut()

flushOut

private void flushOut(org.apache.hc.core5.http.nio.DataStreamChannel chan)
               throws java.io.IOException

Throws:

java.io.IOException

failed

public void failed(java.lang.Exception cause)

Specified by:

failed in interface org.apache.hc.core5.http.nio.AsyncEntityProducer

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface org.apache.hc.core5.http.nio.ResourceHolder