akka.stream.actor

Class ZeroRequestStrategy$

java.lang.Object

akka.stream.actor.ZeroRequestStrategy$

All Implemented Interfaces:

RequestStrategy, java.io.Serializable, scala.Equals, scala.Product

public class ZeroRequestStrategy$
extends java.lang.Object
implements RequestStrategy, scala.Product, scala.Serializable

When request is only controlled with manual calls to ActorSubscriber.request(long).

See Also:

Serialized Form

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ZeroRequestStrategy$()

Method Summary

Modifier and Type	Method and Description
ZeroRequestStrategy$	getInstance() Java API: get the singleton instance
int	requestDemand(int remainingRequested) Invoked by the ActorSubscriber after each incoming message to determine how many more elements to request from the stream.

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 ZeroRequestStrategy$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ZeroRequestStrategy$

public ZeroRequestStrategy$()

Method Detail

requestDemand

public int requestDemand(int remainingRequested)

Description copied from interface: RequestStrategy

Invoked by the ActorSubscriber after each incoming message to determine how many more elements to request from the stream.

Specified by:

requestDemand in interface RequestStrategy

Parameters:

remainingRequested - current remaining number of elements that have been requested from upstream but not received yet

Returns:

demand of more elements from the stream, returning 0 means that no more elements will be requested for now

getInstance

public ZeroRequestStrategy$ getInstance()

Java API: get the singleton instance

Returns:

(undocumented)