Package akka.stream.actor
Class ActorPublisherMessage.SubscriptionTimeoutExceeded$
- java.lang.Object
-
- akka.stream.actor.ActorPublisherMessage
-
- akka.stream.actor.ActorPublisherMessage.SubscriptionTimeoutExceeded
-
- akka.stream.actor.ActorPublisherMessage.SubscriptionTimeoutExceeded$
-
- All Implemented Interfaces:
DeadLetterSuppression,NoSerializationVerificationNeeded,java.io.Serializable,scala.Equals,scala.Product,scala.Serializable
- Enclosing class:
- ActorPublisherMessage
public static final class ActorPublisherMessage.SubscriptionTimeoutExceeded$ extends ActorPublisherMessage.SubscriptionTimeoutExceeded implements NoSerializationVerificationNeeded, scala.Product, scala.Serializable
This message is delivered to theActorPublisheractor in order to signal the exceeding of an subscription timeout. Once the actor receives this message, this publisher will already be in canceled state, thus the actor should clean-up and stop itself.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.stream.actor.ActorPublisherMessage
ActorPublisherMessage.Cancel, ActorPublisherMessage.Cancel$, ActorPublisherMessage.Request, ActorPublisherMessage.Request$, ActorPublisherMessage.SubscriptionTimeoutExceeded, ActorPublisherMessage.SubscriptionTimeoutExceeded$
-
-
Field Summary
Fields Modifier and Type Field Description static ActorPublisherMessage.SubscriptionTimeoutExceeded$MODULE$Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description SubscriptionTimeoutExceeded$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancanEqual(java.lang.Object x$1)inthashCode()intproductArity()java.lang.ObjectproductElement(int x$1)scala.collection.Iterator<java.lang.Object>productIterator()java.lang.StringproductPrefix()java.lang.StringtoString()-
Methods inherited from class akka.stream.actor.ActorPublisherMessage
cancelInstance, subscriptionTimeoutExceededInstance
-
-
-
-
Field Detail
-
MODULE$
public static final ActorPublisherMessage.SubscriptionTimeoutExceeded$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefixin interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArityin interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElementin interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIteratorin interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqualin interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-