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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	StreamRefAttributes.BufferCapacity
static class	StreamRefAttributes.BufferCapacity$
static final class	StreamRefAttributes.DemandRedeliveryInterval
static class	StreamRefAttributes.DemandRedeliveryInterval$
static final class	StreamRefAttributes.FinalTerminationSignalDeadline
static class	StreamRefAttributes.FinalTerminationSignalDeadline$
static interface	StreamRefAttributes.StreamRefAttribute	Attributes specific to stream refs.
static final class	StreamRefAttributes.SubscriptionTimeout
static class	StreamRefAttributes.SubscriptionTimeout$

Constructor Summary

Constructors

Constructor	Description
StreamRefAttributes()

Method Summary

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

Constructor Details

StreamRefAttributes

public StreamRefAttributes()

Method Details

subscriptionTimeout

public static 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 static 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 static Attributes bufferCapacity(int capacity)

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

demandRedeliveryInterval

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

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

demandRedeliveryInterval

public static Attributes demandRedeliveryInterval(Duration timeout)

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

finalTerminationSignalDeadline

public static 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 static Attributes finalTerminationSignalDeadline(Duration timeout)

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