Package akka.stream.actor

Class ActorPublisherMessage$

java.lang.Object

akka.stream.actor.ActorPublisherMessage$

public class ActorPublisherMessage$
extends java.lang.Object

This message is delivered to the ActorPublisher actor when the stream subscriber requests more elements. param: n number of requested elements

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ActorPublisherMessage$()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final ActorPublisherMessage$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ActorPublisherMessage$

public ActorPublisherMessage$()

Method Detail

cancelInstance

public ActorPublisherMessage.Cancel$ cancelInstance()

subscriptionTimeoutExceededInstance

public ActorPublisherMessage.SubscriptionTimeoutExceeded$ subscriptionTimeoutExceededInstance()