public class Decoder extends GraphStageWithMaterializedValue<FlowShape<EnvelopeBuffer,InboundEnvelope>,Decoder.InboundCompressionAccess>
Modifier and Type | Class and Description |
---|---|
static class |
Decoder.AccessInboundCompressionFailed |
static interface |
Decoder.InboundCompressionAccess
Materialized value of
Encoder which allows safely calling into the stage to interfact with compression tables. |
static interface |
Decoder.InboundCompressionAccessImpl |
Constructor and Description |
---|
Decoder(InboundContext inboundContext,
ExtendedActorSystem system,
UniqueAddress uniqueLocalAddress,
ArterySettings settings,
EnvelopeBufferPool bufferPool,
InboundCompressions inboundCompressions,
ObjectPool<ReusableInboundEnvelope> inEnvelopePool) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static Graph<S,M> |
async() |
scala.Tuple2<GraphStageLogic,Decoder.InboundCompressionAccess> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Inlet<EnvelopeBuffer> |
in() |
protected static Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
Outlet<InboundEnvelope> |
out() |
FlowShape<EnvelopeBuffer,InboundEnvelope> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
static Graph<S,M> |
withAttributes(Attributes attr) |
initialAttributes, module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public Decoder(InboundContext inboundContext, ExtendedActorSystem system, UniqueAddress uniqueLocalAddress, ArterySettings settings, EnvelopeBufferPool bufferPool, InboundCompressions inboundCompressions, ObjectPool<ReusableInboundEnvelope> inEnvelopePool)
public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
protected static Attributes initialAttributes()
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public Inlet<EnvelopeBuffer> in()
public Outlet<InboundEnvelope> out()
public FlowShape<EnvelopeBuffer,InboundEnvelope> shape()
Graph
public scala.Tuple2<GraphStageLogic,Decoder.InboundCompressionAccess> createLogicAndMaterializedValue(Attributes inheritedAttributes)