Package akka.remote.artery
Interface Decoder.InboundCompressionAccess
-
- All Known Subinterfaces:
Decoder.InboundCompressionAccessImpl
- Enclosing class:
- Decoder
public static interface Decoder.InboundCompressionAccess
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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 purposesvoid
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.
-
-