-
Notifications
You must be signed in to change notification settings - Fork 983
Add Zstandardto async content compression #703
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add Zstandardto async content compression #703
Conversation
...nt5/src/test/java/org/apache/hc/client5/http/examples/AsyncClientZstdCompressionExample.java
Fixed
Show fixed
Hide fixed
| */ | ||
| private final ZstdDirectBufferCompressingStream zstream; | ||
|
|
||
| private volatile boolean upstreamEnded = false; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Initializing to default values creates clutter IMO.
d9ec312 to
d872969
Compare
2f61f39 to
4fef0bb
Compare
...ent5/src/main/java/org/apache/hc/client5/http/async/methods/DeflatingZstdEntityProducer.java
Outdated
Show resolved
Hide resolved
...client5/src/main/java/org/apache/hc/client5/http/impl/async/ContentCompressionAsyncExec.java
Outdated
Show resolved
Hide resolved
...client5/src/main/java/org/apache/hc/client5/http/impl/async/ContentCompressionAsyncExec.java
Outdated
Show resolved
Hide resolved
1d8266f to
7ade7d7
Compare
|
@ok2c please do another pass. |
pom.xml
Outdated
| <groupId>com.github.luben</groupId> | ||
| <artifactId>zstd-jni</artifactId> | ||
| <version>${zstd.jni.version}</version> | ||
| <optional>true</optional> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@arturobernalg This is unnecessary in the dependency management section.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
removed.
Wire InflatingZstdDataConsumer; add DeflatingZstdEntityProducer for streaming requests
26fe12f to
2d8d387
Compare
Adds transparent zstd response decoding via
ContentCompressionAsyncExec(InflatingZstdDataConsumer).Provides
DeflatingZstdEntityProducerfor streaming request compression.Examples:
AsyncClientServerZstdExample+AsyncClientZstdCompressionExample;