Package akka.remote.artery
Interface Decoder.InboundCompressionAccessImpl
-
- All Superinterfaces:
Decoder.InboundCompressionAccess
- Enclosing class:
- Decoder
public static interface Decoder.InboundCompressionAccessImpl extends Decoder.InboundCompressionAccess
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.concurrent.Future<Done>
closeCompressionFor(long originUid)
External call from ChangeInboundCompression materialized valueInboundCompressions
compressions()
scala.concurrent.Future<Done>
confirmActorRefCompressionAdvertisementAck(CompressionProtocol.ActorRefCompressionAdvertisementAck ack)
External call from ChangeInboundCompression materialized valuescala.concurrent.Future<Done>
confirmClassManifestCompressionAdvertisementAck(CompressionProtocol.ClassManifestCompressionAdvertisementAck ack)
External call from ChangeInboundCompression materialized valuescala.concurrent.Future<scala.collection.immutable.Set<java.lang.Object>>
currentCompressionOriginUids()
External call from ChangeInboundCompression materialized valuevoid
runNextActorRefAdvertisement()
External call from ChangeInboundCompression materialized valuevoid
runNextClassManifestAdvertisement()
External call from ChangeInboundCompression materialized value
-
-
-
Method Detail
-
closeCompressionFor
scala.concurrent.Future<Done> closeCompressionFor(long originUid)
External call from ChangeInboundCompression materialized value- Specified by:
closeCompressionFor
in interfaceDecoder.InboundCompressionAccess
- Parameters:
originUid
- (undocumented)- Returns:
- (undocumented)
-
compressions
InboundCompressions compressions()
-
confirmActorRefCompressionAdvertisementAck
scala.concurrent.Future<Done> confirmActorRefCompressionAdvertisementAck(CompressionProtocol.ActorRefCompressionAdvertisementAck ack)
External call from ChangeInboundCompression materialized value- Specified by:
confirmActorRefCompressionAdvertisementAck
in interfaceDecoder.InboundCompressionAccess
- Parameters:
ack
- (undocumented)- Returns:
- (undocumented)
-
confirmClassManifestCompressionAdvertisementAck
scala.concurrent.Future<Done> confirmClassManifestCompressionAdvertisementAck(CompressionProtocol.ClassManifestCompressionAdvertisementAck ack)
External call from ChangeInboundCompression materialized value- Specified by:
confirmClassManifestCompressionAdvertisementAck
in interfaceDecoder.InboundCompressionAccess
- Parameters:
ack
- (undocumented)- Returns:
- (undocumented)
-
currentCompressionOriginUids
scala.concurrent.Future<scala.collection.immutable.Set<java.lang.Object>> currentCompressionOriginUids()
External call from ChangeInboundCompression materialized value- Specified by:
currentCompressionOriginUids
in interfaceDecoder.InboundCompressionAccess
- Returns:
- (undocumented)
-
runNextActorRefAdvertisement
void runNextActorRefAdvertisement()
External call from ChangeInboundCompression materialized value- Specified by:
runNextActorRefAdvertisement
in interfaceDecoder.InboundCompressionAccess
-
runNextClassManifestAdvertisement
void runNextClassManifestAdvertisement()
External call from ChangeInboundCompression materialized value- Specified by:
runNextClassManifestAdvertisement
in interfaceDecoder.InboundCompressionAccess
-
-