Package akka.stream.actor

Class ActorPublisherMessage

java.lang.Object

akka.stream.actor.ActorPublisherMessage

All Implemented Interfaces:

DeadLetterSuppression

Direct Known Subclasses:

ActorPublisherMessage.Cancel, ActorPublisherMessage.Request, ActorPublisherMessage.SubscriptionTimeoutExceeded

public abstract class ActorPublisherMessage
extends java.lang.Object
implements DeadLetterSuppression

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ActorPublisherMessage.Cancel
static class	ActorPublisherMessage.Cancel$
static class	ActorPublisherMessage.Request
static class	ActorPublisherMessage.Request$
static class	ActorPublisherMessage.SubscriptionTimeoutExceeded
static class	ActorPublisherMessage.SubscriptionTimeoutExceeded$	This message is delivered to the ActorPublisher actor in order to signal the exceeding of an subscription timeout.

Constructor Summary

Constructors

Constructor	Description
ActorPublisherMessage()

Method Summary

Modifier and Type	Method	Description
static ActorPublisherMessage.Cancel$	cancelInstance()
static ActorPublisherMessage.SubscriptionTimeoutExceeded$	subscriptionTimeoutExceededInstance()

Methods inherited from class java.lang.Object

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

Constructor Detail

ActorPublisherMessage

public ActorPublisherMessage()

Method Detail

cancelInstance

public static ActorPublisherMessage.Cancel$ cancelInstance()

subscriptionTimeoutExceededInstance

public static ActorPublisherMessage.SubscriptionTimeoutExceeded$ subscriptionTimeoutExceededInstance()