public class Deflate extends java.lang.Object implements Coder, StreamDecoder
Constructor and Description |
---|
Deflate(scala.Function1<HttpMessage,java.lang.Object> messageFilter)
Deprecated.
|
Deflate(int compressionLevel,
scala.Function1<HttpMessage,java.lang.Object> messageFilter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static scala.concurrent.Future<org.apache.pekko.util.ByteString> |
decode(org.apache.pekko.util.ByteString input,
org.apache.pekko.stream.Materializer mat)
Deprecated.
|
static <T> T |
decodeData(T t,
DataMapper<T> mapper)
Deprecated.
|
static org.apache.pekko.http.scaladsl.coding.Decoder.message |
decodeMessage(HttpMessage message)
Deprecated.
|
static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> |
decoderFlow()
Deprecated.
|
static org.apache.pekko.util.ByteString |
encode(org.apache.pekko.util.ByteString input)
Deprecated.
|
static scala.concurrent.Future<org.apache.pekko.util.ByteString> |
encodeAsync(org.apache.pekko.util.ByteString input,
org.apache.pekko.stream.Materializer mat)
Deprecated.
|
static <T> T |
encodeData(T t,
DataMapper<T> mapper)
Deprecated.
|
static org.apache.pekko.http.scaladsl.coding.Encoder.message |
encodeMessage(HttpMessage message)
Deprecated.
|
static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> |
encoderFlow()
Deprecated.
|
HttpEncoding |
encoding()
Deprecated.
|
static int |
maxBytesPerChunk()
Deprecated.
|
scala.Function1<HttpMessage,java.lang.Object> |
messageFilter()
Deprecated.
|
DeflateCompressor |
newCompressor()
Deprecated.
|
scala.Function0<DeflateDecompressor> |
newDecompressorStage(int maxBytesPerChunk)
Deprecated.
|
static org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>> |
newEncodeTransformer()
Deprecated.
|
Deflate |
withLevel(int level)
Deprecated.
Use Coders.Deflate(compressionLevel = ...) instead. Since Akka HTTP 10.2.0.
|
static Decoder |
withMaxBytesPerChunk(int newMaxBytesPerChunk)
Deprecated.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
encode, encodeAsync, encodeData, encodeMessage, encoderFlow, newEncodeTransformer, singleUseEncoderFlow
decoderFlow, maxBytesPerChunk, withMaxBytesPerChunk
decode, decodeData, decodeMessage
public Deflate(int compressionLevel, scala.Function1<HttpMessage,java.lang.Object> messageFilter)
public Deflate(scala.Function1<HttpMessage,java.lang.Object> messageFilter)
public static org.apache.pekko.http.scaladsl.coding.Encoder.message encodeMessage(HttpMessage message)
public static <T> T encodeData(T t, DataMapper<T> mapper)
public static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> encoderFlow()
public static org.apache.pekko.util.ByteString encode(org.apache.pekko.util.ByteString input)
public static scala.concurrent.Future<org.apache.pekko.util.ByteString> encodeAsync(org.apache.pekko.util.ByteString input, org.apache.pekko.stream.Materializer mat)
public static org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>> newEncodeTransformer()
public static org.apache.pekko.http.scaladsl.coding.Decoder.message decodeMessage(HttpMessage message)
public static <T> T decodeData(T t, DataMapper<T> mapper)
public static scala.concurrent.Future<org.apache.pekko.util.ByteString> decode(org.apache.pekko.util.ByteString input, org.apache.pekko.stream.Materializer mat)
public static int maxBytesPerChunk()
public static Decoder withMaxBytesPerChunk(int newMaxBytesPerChunk)
public static org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> decoderFlow()
public scala.Function1<HttpMessage,java.lang.Object> messageFilter()
messageFilter
in interface Encoder
public HttpEncoding encoding()
public DeflateCompressor newCompressor()
newCompressor
in interface Encoder
public scala.Function0<DeflateDecompressor> newDecompressorStage(int maxBytesPerChunk)
newDecompressorStage
in interface StreamDecoder
public Deflate withLevel(int level)