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

Enclosing class:

ActorPublisherMessage

public static final class ActorPublisherMessage.SubscriptionTimeoutExceeded$
extends ActorPublisherMessage.SubscriptionTimeoutExceeded
implements NoSerializationVerificationNeeded, scala.Product, scala.Serializable

This message is delivered to the ActorPublisher actor 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 and Description
static ActorPublisherMessage.SubscriptionTimeoutExceeded$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
SubscriptionTimeoutExceeded$()

Method Summary

Methods inherited from class akka.stream.actor.ActorPublisherMessage

cancelInstance, subscriptionTimeoutExceededInstance

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Field Detail

MODULE$

public static final ActorPublisherMessage.SubscriptionTimeoutExceeded$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

SubscriptionTimeoutExceeded$

public SubscriptionTimeoutExceeded$()