public class NoCoding
extends java.lang.Object
Constructor and Description |
---|
NoCoding() |
Modifier and Type | Method and Description |
---|---|
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 <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() |
static HttpEncoding |
encoding() |
static int |
maxBytesPerChunk() |
static scala.Function1<HttpMessage,java.lang.Object> |
messageFilter() |
static NoCodingCompressor$ |
newCompressor() |
static scala.Function0<akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,akka.util.ByteString>>> |
newDecompressorStage(int maxBytesPerChunk) |
static akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,akka.util.ByteString>> |
newEncodeTransformer() |
static Decoder |
withMaxBytesPerChunk(int newMaxBytesPerChunk) |
public static HttpEncoding encoding()
public static <T extends HttpMessage> HttpMessage encode(T message, DataMapper<T> mapper)
public static <T> T encodeData(T t, DataMapper<T> mapper)
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.Function1<HttpMessage,java.lang.Object> messageFilter()
public static NoCodingCompressor$ newCompressor()
public static scala.Function0<akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,akka.util.ByteString>>> newDecompressorStage(int maxBytesPerChunk)
public static akka.http.scaladsl.coding.Encoder.message encodeMessage(HttpMessage message)
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 int maxBytesPerChunk()
public static Decoder withMaxBytesPerChunk(int newMaxBytesPerChunk)
public static akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> decoderFlow()