public class Gzip extends java.lang.Object implements Coder, StreamDecoder
Constructor and Description |
---|
Gzip(scala.Function1<HttpMessage,java.lang.Object> messageFilter) |
Modifier and Type | Method and Description |
---|---|
static Gzip |
apply(scala.Function1<HttpMessage,java.lang.Object> messageFilter) |
static scala.concurrent.Future<akka.util.ByteString> |
decode(akka.util.ByteString input,
akka.stream.Materializer mat) |
static <T extends HttpMessage> |
decode(T message,
DataMapper<T> mapper) |
static <T> T |
decodeData(T t,
DataMapper<T> mapper) |
static akka.http.scaladsl.coding.Decoder.message |
decodeMessage(HttpMessage message) |
static akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> |
decoderFlow() |
static akka.util.ByteString |
encode(akka.util.ByteString input) |
static <T extends HttpMessage> |
encode(T message,
DataMapper<T> mapper) |
static <T> T |
encodeData(T t,
DataMapper<T> mapper) |
static akka.http.scaladsl.coding.Encoder.message |
encodeMessage(HttpMessage message) |
static akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> |
encoderFlow() |
HttpEncoding |
encoding() |
static int |
maxBytesPerChunk() |
scala.Function1<HttpMessage,java.lang.Object> |
messageFilter() |
GzipCompressor |
newCompressor() |
scala.Function0<GzipDecompressor> |
newDecompressorStage(int maxBytesPerChunk) |
static akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,akka.util.ByteString>> |
newEncodeTransformer() |
static Decoder |
withMaxBytesPerChunk(int newMaxBytesPerChunk) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
encode, encode, encodeData, encodeMessage, encoderFlow, newEncodeTransformer
decoderFlow, maxBytesPerChunk, withMaxBytesPerChunk
decode, decode, decodeData, decodeMessage
public Gzip(scala.Function1<HttpMessage,java.lang.Object> messageFilter)
public static Gzip apply(scala.Function1<HttpMessage,java.lang.Object> messageFilter)
public static akka.http.scaladsl.coding.Encoder.message encodeMessage(HttpMessage message)
public static <T extends HttpMessage> HttpMessage encode(T message, DataMapper<T> mapper)
public static <T> T encodeData(T t, DataMapper<T> mapper)
public static akka.util.ByteString encode(akka.util.ByteString input)
public static akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> encoderFlow()
public static akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,akka.util.ByteString>> newEncodeTransformer()
public static akka.http.scaladsl.coding.Decoder.message decodeMessage(HttpMessage message)
public static <T extends HttpMessage> HttpMessage decode(T message, DataMapper<T> mapper)
public static <T> T decodeData(T t, DataMapper<T> mapper)
public static scala.concurrent.Future<akka.util.ByteString> decode(akka.util.ByteString input, akka.stream.Materializer mat)
public static int maxBytesPerChunk()
public static Decoder withMaxBytesPerChunk(int newMaxBytesPerChunk)
public static akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> decoderFlow()
public scala.Function1<HttpMessage,java.lang.Object> messageFilter()
messageFilter
in interface Encoder
public HttpEncoding encoding()
public GzipCompressor newCompressor()
newCompressor
in interface Encoder
public scala.Function0<GzipDecompressor> newDecompressorStage(int maxBytesPerChunk)
newDecompressorStage
in interface StreamDecoder