Package org.apache.pekko.remote.artery.compress

Class NoInboundCompressions$

java.lang.Object

org.apache.pekko.remote.artery.compress.NoInboundCompressions$

All Implemented Interfaces:

Serializable, InboundCompressions, scala.Equals, scala.Product

public class NoInboundCompressions$
extends Object
implements InboundCompressions, scala.Product, Serializable

INTERNAL API

Literarily, no compression!

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final NoInboundCompressions$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
NoInboundCompressions$()

Method Summary

Modifier and Type	Method	Description
boolean	canEqual(Object x$1)
void	close(long originUid)	Remove compression and cancel advertisement scheduling for a specific origin
void	confirmActorRefCompressionAdvertisement(long originUid, byte tableVersion)
void	confirmClassManifestCompressionAdvertisement(long originUid, byte tableVersion)
scala.collection.immutable.Set<Object>	currentOriginUids()
<any>	decompressActorRef(long originUid, byte tableVersion, int idx)
<any>	decompressClassManifest(long originUid, byte tableVersion, int idx)
int	hashCode()
void	hitActorRef(long originUid, Address remote, ActorRef ref, int n)
void	hitClassManifest(long originUid, Address remote, String manifest, int n)
int	productArity()
Object	productElement(int x$1)
scala.collection.Iterator<Object>	productIterator()
String	productPrefix()
void	runNextActorRefAdvertisement()	Triggers compression advertisement via control message.
void	runNextClassManifestAdvertisement()	Triggers compression advertisement via control message.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Equals

equals

Methods inherited from interface scala.Product

productElementName, productElementNames

Field Details

MODULE$

public static final NoInboundCompressions$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

NoInboundCompressions$

public NoInboundCompressions$()

Method Details

hitActorRef

public void hitActorRef(long originUid,
 Address remote,
 ActorRef ref,
 int n)

Specified by:

hitActorRef in interface InboundCompressions

decompressActorRef

public <any> decompressActorRef(long originUid,
 byte tableVersion,
 int idx)

Specified by:

decompressActorRef in interface InboundCompressions

confirmActorRefCompressionAdvertisement

public void confirmActorRefCompressionAdvertisement(long originUid,
 byte tableVersion)

Specified by:

confirmActorRefCompressionAdvertisement in interface InboundCompressions

runNextActorRefAdvertisement

public void runNextActorRefAdvertisement()

Description copied from interface: InboundCompressions

Triggers compression advertisement via control message.

Specified by:

runNextActorRefAdvertisement in interface InboundCompressions

hitClassManifest

public void hitClassManifest(long originUid,
 Address remote,
 String manifest,
 int n)

Specified by:

hitClassManifest in interface InboundCompressions

decompressClassManifest

public <any> decompressClassManifest(long originUid,
 byte tableVersion,
 int idx)

Specified by:

decompressClassManifest in interface InboundCompressions

confirmClassManifestCompressionAdvertisement

public void confirmClassManifestCompressionAdvertisement(long originUid,
 byte tableVersion)

Specified by:

confirmClassManifestCompressionAdvertisement in interface InboundCompressions

runNextClassManifestAdvertisement

public void runNextClassManifestAdvertisement()

Description copied from interface: InboundCompressions

Triggers compression advertisement via control message.

Specified by:

runNextClassManifestAdvertisement in interface InboundCompressions

currentOriginUids

public scala.collection.immutable.Set<Object> currentOriginUids()

Specified by:

currentOriginUids in interface InboundCompressions

close

public void close(long originUid)

Description copied from interface: InboundCompressions

Remove compression and cancel advertisement scheduling for a specific origin

Specified by:

close in interface InboundCompressions

productPrefix

public String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(Object x$1)

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object