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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ActorPublisherMessage.Cancel
static class	ActorPublisherMessage.Cancel$ This message is delivered to the ActorPublisher actor when the stream subscriber cancels the subscription.
static class	ActorPublisherMessage.Request This message is delivered to the ActorPublisher actor when the stream subscriber requests more elements.
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 and Description
ActorPublisherMessage()

Method Summary

Modifier and Type	Method and Description
static ActorPublisherMessage.Cancel$	cancelInstance() Java API: get the singleton instance of the Cancel message
static ActorPublisherMessage.SubscriptionTimeoutExceeded$	subscriptionTimeoutExceededInstance() Java API: get the singleton instance of the SubscriptionTimeoutExceeded message

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()

Java API: get the singleton instance of the Cancel message

Returns:

(undocumented)

subscriptionTimeoutExceededInstance

public static ActorPublisherMessage.SubscriptionTimeoutExceeded$ subscriptionTimeoutExceededInstance()

Java API: get the singleton instance of the SubscriptionTimeoutExceeded message

Returns:

(undocumented)