akka.stream.actor

Class ActorPublisherMessage.Request

java.lang.Object

akka.stream.actor.ActorPublisherMessage

akka.stream.actor.ActorPublisherMessage.Request

All Implemented Interfaces:

DeadLetterSuppression, NoSerializationVerificationNeeded, java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

ActorPublisherMessage

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

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

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$

Constructor Summary

Constructors

Constructor and Description
Request(long n)

Method Summary

Modifier and Type	Method and Description
boolean	isProcessed() INTERNAL API: needed for stash support
void	markProcessed() INTERNAL API: needed for stash support
long	n()

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

Constructor Detail

Request

public Request(long n)

Method Detail

n

public long n()

markProcessed

public void markProcessed()

INTERNAL API: needed for stash support

isProcessed

public boolean isProcessed()

INTERNAL API: needed for stash support

Returns:

(undocumented)