akka.remote.artery

Interface Decoder.InboundCompressionAccess

All Known Subinterfaces:

Decoder.InboundCompressionAccessImpl

Enclosing class:

Decoder

public static interface Decoder.InboundCompressionAccess

Materialized value of Encoder which allows safely calling into the stage to interfact with compression tables.

Method Summary

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.

Method Detail

confirmActorRefCompressionAdvertisementAck

scala.concurrent.Future<Done> confirmActorRefCompressionAdvertisementAck(CompressionProtocol.ActorRefCompressionAdvertisementAck ack)

confirmClassManifestCompressionAdvertisementAck

scala.concurrent.Future<Done> confirmClassManifestCompressionAdvertisementAck(CompressionProtocol.ClassManifestCompressionAdvertisementAck ack)

closeCompressionFor

scala.concurrent.Future<Done> closeCompressionFor(long originUid)

runNextActorRefAdvertisement

void runNextActorRefAdvertisement()

For testing purposes, usually triggered by timer from within Decoder stage.

runNextClassManifestAdvertisement

void runNextClassManifestAdvertisement()

For testing purposes, usually triggered by timer from within Decoder stage.