java.lang.Object
- org.apache.hc.client5.http.async.methods.DeflatingAsyncEntityProducer

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 DeflatingAsyncEntityProducer
extends java.lang.Object
implements org.apache.hc.core5.http.nio.AsyncEntityProducer
```
AsyncEntityProducer that streams the output of another producer through the raw DEFLATE compression algorithm.
The delegate’s bytes are read in small chunks, compressed with Deflater and written immediately to the HTTP I/O layer. Memory use is therefore bounded even for very large request entities.

Since:

5.6

Nested Class Summary

Nested Classes
Modifier and Type Class Description

private class DeflatingAsyncEntityProducer.InnerChannel

Field Summary

Fields
Modifier and Type	Field	Description
`private java.lang.String`	`contentType`
`private java.util.zip.Deflater`	`deflater`
`private org.apache.hc.core5.http.nio.AsyncEntityProducer`	`delegate`
`private java.util.concurrent.atomic.AtomicBoolean`	`delegateEnded`
`private boolean`	`finished`
`private byte[]`	`in`
`private static int`	`IN_BUF`	inbound copy‐buffer
`private static int`	`OUT_BUF`	outbound staging buffer
`private java.nio.ByteBuffer`	`pending`	holds compressed bytes not yet sent downstream

Constructor Summary

Constructors
Constructor Description

DeflatingAsyncEntityProducer(org.apache.hc.core5.http.nio.AsyncEntityProducer delegate)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`int`	`available()`
`private void`	`deflateToPending()`	drain `deflater` into `pending`
`void`	`failed(java.lang.Exception cause)`
`private boolean`	`flushPending(org.apache.hc.core5.http.nio.DataStreamChannel ch)`	copy as much as possible from `pending` to the wire
`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 channel)`
`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
```
    inbound copy‐buffer
    
    See Also:
    
    Constant Field Values
  - OUT_BUF
```
private static final int OUT_BUF
```
    outbound staging buffer
    
    See Also:
    
    Constant Field Values
  - delegate
```
private final org.apache.hc.core5.http.nio.AsyncEntityProducer delegate
```
  - contentType
```
private final java.lang.String contentType
```
  - deflater
```
private final java.util.zip.Deflater deflater
```
  - pending
```
private final java.nio.ByteBuffer pending
```
    holds compressed bytes not yet sent downstream
  - in
```
private final byte[] in
```
  - delegateEnded
```
private final java.util.concurrent.atomic.AtomicBoolean delegateEnded
```
  - finished
```
private boolean finished
```
- Constructor Detail
  - DeflatingAsyncEntityProducer
```
public DeflatingAsyncEntityProducer(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 channel)
             throws java.io.IOException
```
    Specified by:
    
    produce in interface org.apache.hc.core5.http.nio.AsyncDataProducer
    
    Throws:
    
    java.io.IOException
  - flushPending
```
private boolean flushPending(org.apache.hc.core5.http.nio.DataStreamChannel ch)
                      throws java.io.IOException
```
    copy as much as possible from pending to the wire
    
    Throws:
    
    java.io.IOException
  - deflateToPending
```
private void deflateToPending()
```
    drain deflater into pending
  - 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

Class DeflatingAsyncEntityProducer

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

IN_BUF

OUT_BUF

delegate

contentType

deflater

pending

in

delegateEnded

finished

Constructor Detail

DeflatingAsyncEntityProducer

Method Detail

isRepeatable

getContentLength

getContentType

getContentEncoding

isChunked

getTrailerNames

available

produce

flushPending

deflateToPending

failed

releaseResources