Package org.apache.pekko.stream

Class StreamRefAttributes$

java.lang.Object

org.apache.pekko.stream.StreamRefAttributes$

public class StreamRefAttributes$
extends Object

Attributes for stream refs (pekko.stream.SourceRef and pekko.stream.SinkRef). Note that more attributes defined in Attributes and ActorAttributes.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
StreamRefAttributes$()

Method Summary

Modifier and Type	Method	Description
Attributes	bufferCapacity(int capacity)	Specifies the size of the buffer on the receiving side that is eagerly filled even without demand.
Attributes	demandRedeliveryInterval(Duration timeout)	Java API: If no new elements arrive within this timeout, demand is redelivered.
Attributes	demandRedeliveryInterval(scala.concurrent.duration.FiniteDuration timeout)	Scala API: If no new elements arrive within this timeout, demand is redelivered.
Attributes	finalTerminationSignalDeadline(Duration timeout)	Java API: The time between the Terminated signal being received and when the local SourceRef determines to fail itself
Attributes	finalTerminationSignalDeadline(scala.concurrent.duration.FiniteDuration timeout)	Scala API: The time between the Terminated signal being received and when the local SourceRef determines to fail itself
Attributes	subscriptionTimeout(Duration timeout)	Java API: Specifies the subscription timeout within which the remote side MUST subscribe to the handed out stream reference.
Attributes	subscriptionTimeout(scala.concurrent.duration.FiniteDuration timeout)	Scala API: Specifies the subscription timeout within which the remote side MUST subscribe to the handed out stream reference.

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final StreamRefAttributes$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

StreamRefAttributes$

public StreamRefAttributes$()

Method Details

subscriptionTimeout

public Attributes subscriptionTimeout(scala.concurrent.duration.FiniteDuration timeout)

Scala API: Specifies the subscription timeout within which the remote side MUST subscribe to the handed out stream reference.

subscriptionTimeout

public Attributes subscriptionTimeout(Duration timeout)

Java API: Specifies the subscription timeout within which the remote side MUST subscribe to the handed out stream reference.

bufferCapacity

public Attributes bufferCapacity(int capacity)

Specifies the size of the buffer on the receiving side that is eagerly filled even without demand.

demandRedeliveryInterval

public Attributes demandRedeliveryInterval(scala.concurrent.duration.FiniteDuration timeout)

Scala API: If no new elements arrive within this timeout, demand is redelivered.

demandRedeliveryInterval

public Attributes demandRedeliveryInterval(Duration timeout)

Java API: If no new elements arrive within this timeout, demand is redelivered.

finalTerminationSignalDeadline

public Attributes finalTerminationSignalDeadline(scala.concurrent.duration.FiniteDuration timeout)

Scala API: The time between the Terminated signal being received and when the local SourceRef determines to fail itself

finalTerminationSignalDeadline

public Attributes finalTerminationSignalDeadline(Duration timeout)

Java API: The time between the Terminated signal being received and when the local SourceRef determines to fail itself