Package akka.stream

Class StreamRefAttributes

    • Constructor Detail

      • StreamRefAttributes

        public StreamRefAttributes()
    • Method Detail

      • 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​(java.time.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​(java.time.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​(java.time.Duration timeout)
        Java API: The time between the Terminated signal being received and when the local SourceRef determines to fail itself