org.apache.pekko.http.scaladsl.coding

Interface Encoder

All Known Subinterfaces:

Coder

All Known Implementing Classes:

Deflate, Deflate$, Gzip, Gzip$, NoCoding$

public interface Encoder

Method Summary

Modifier and Type	Method and Description
org.apache.pekko.util.ByteString	encode(org.apache.pekko.util.ByteString input) Deprecated. synchronous compression with `encode` is not supported in the future any more, use `encodeAsync` instead. Since Akka HTTP 10.2.0.
scala.concurrent.Future<org.apache.pekko.util.ByteString>	encodeAsync(org.apache.pekko.util.ByteString input, org.apache.pekko.stream.Materializer mat)
<T> T	encodeData(T t, DataMapper<T> mapper)
org.apache.pekko.http.scaladsl.coding.Encoder.message	encodeMessage(HttpMessage message)
org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>	encoderFlow()
HttpEncoding	encoding()
scala.Function1<HttpMessage,java.lang.Object>	messageFilter()
Compressor	newCompressor() Deprecated. newCompressor is internal API. Since Akka HTTP 10.2.0.
org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>>	newEncodeTransformer() Deprecated. newEncodeTransformer is internal API. Since Akka HTTP 10.2.0.
org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>>	singleUseEncoderFlow()

Method Detail

encoding

HttpEncoding encoding()

messageFilter

scala.Function1<HttpMessage,java.lang.Object> messageFilter()

encodeMessage

org.apache.pekko.http.scaladsl.coding.Encoder.message encodeMessage(HttpMessage message)

encodeData

<T> T encodeData(T t,
                 DataMapper<T> mapper)

encoderFlow

org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> encoderFlow()

encode

org.apache.pekko.util.ByteString encode(org.apache.pekko.util.ByteString input)

Deprecated. synchronous compression with `encode` is not supported in the future any more, use `encodeAsync` instead. Since Akka HTTP 10.2.0.

encodeAsync

scala.concurrent.Future<org.apache.pekko.util.ByteString> encodeAsync(org.apache.pekko.util.ByteString input,
                                                                      org.apache.pekko.stream.Materializer mat)

newCompressor

Compressor newCompressor()

Deprecated. newCompressor is internal API. Since Akka HTTP 10.2.0.

newEncodeTransformer

org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>> newEncodeTransformer()

Deprecated. newEncodeTransformer is internal API. Since Akka HTTP 10.2.0.

singleUseEncoderFlow

org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>> singleUseEncoderFlow()