public static interface Decoder.InboundCompressionAccess
Encoder
which allows safely calling into the stage to interfact with compression tables.Modifier and Type | Method and Description |
---|---|
scala.concurrent.Future<Done> |
closeCompressionFor(long originUid) |
scala.concurrent.Future<Done> |
confirmActorRefCompressionAdvertisementAck(CompressionProtocol.ActorRefCompressionAdvertisementAck ack) |
scala.concurrent.Future<Done> |
confirmClassManifestCompressionAdvertisementAck(CompressionProtocol.ClassManifestCompressionAdvertisementAck ack) |
void |
runNextActorRefAdvertisement()
For testing purposes, usually triggered by timer from within Decoder stage.
|
void |
runNextClassManifestAdvertisement()
For testing purposes, usually triggered by timer from within Decoder stage.
|
scala.concurrent.Future<Done> confirmActorRefCompressionAdvertisementAck(CompressionProtocol.ActorRefCompressionAdvertisementAck ack)
scala.concurrent.Future<Done> confirmClassManifestCompressionAdvertisementAck(CompressionProtocol.ClassManifestCompressionAdvertisementAck ack)
scala.concurrent.Future<Done> closeCompressionFor(long originUid)
void runNextActorRefAdvertisement()
void runNextClassManifestAdvertisement()