o

akka.stream

StreamRefAttributes

object StreamRefAttributes

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

Source
Attributes.scala
Linear Supertypes
AnyRef, Any
Content Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamRefAttributes
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final case class BufferCapacity(capacity: Int) extends with Product with Serializable
  2. final case class DemandRedeliveryInterval(timeout: FiniteDuration) extends with Product with Serializable
  3. final case class FinalTerminationSignalDeadline(timeout: FiniteDuration) extends with Product with Serializable
  4. sealed trait StreamRefAttribute extends Attribute

    Attributes specific to stream refs.

    Attributes specific to stream refs.

    Not for user extension.

    Annotations
    @DoNotInherit()
  5. final case class SubscriptionTimeout(timeout: FiniteDuration) extends with Product with Serializable

Value Members

  1. def bufferCapacity(capacity: Int): Attributes

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

  2. def demandRedeliveryInterval(timeout: Duration): Attributes

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

  3. def demandRedeliveryInterval(timeout: FiniteDuration): Attributes

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

  4. def finalTerminationSignalDeadline(timeout: Duration): Attributes

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

  5. def finalTerminationSignalDeadline(timeout: FiniteDuration): Attributes

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

  6. def subscriptionTimeout(timeout: Duration): Attributes

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

  7. def subscriptionTimeout(timeout: FiniteDuration): Attributes

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