Package akka.remote.artery

Interface Decoder.InboundCompressionAccess

All Known Subinterfaces:

Decoder.InboundCompressionAccessImpl

Enclosing class:

Decoder

public static interface Decoder.InboundCompressionAccess

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<Done>	closeCompressionFor(long originUid)
scala.concurrent.Future<Done>	confirmActorRefCompressionAdvertisementAck(CompressionProtocol.ActorRefCompressionAdvertisementAck ack)
scala.concurrent.Future<Done>	confirmClassManifestCompressionAdvertisementAck(CompressionProtocol.ClassManifestCompressionAdvertisementAck ack)
scala.concurrent.Future<scala.collection.immutable.Set<java.lang.Object>>	currentCompressionOriginUids()	For testing purposes
void	runNextActorRefAdvertisement()	For testing purposes, usually triggered by timer from within Decoder operator.
void	runNextClassManifestAdvertisement()	For testing purposes, usually triggered by timer from within Decoder operator.

Method Detail

closeCompressionFor

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

confirmActorRefCompressionAdvertisementAck

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

confirmClassManifestCompressionAdvertisementAck

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

currentCompressionOriginUids

scala.concurrent.Future<scala.collection.immutable.Set<java.lang.Object>> currentCompressionOriginUids()

For testing purposes

runNextActorRefAdvertisement

void runNextActorRefAdvertisement()

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

runNextClassManifestAdvertisement

void runNextClassManifestAdvertisement()

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