object Timers

INTERNAL API

Various stages for controlling timeouts on IO related streams (although not necessarily).

The common theme among the processing stages here that

  • they wait for certain event or events to happen
  • they have a timer that may fire before these events
  • if the timer fires before the event happens, these stages all fail the stream
  • otherwise, these streams do not interfere with the element flow, ordinary completion or failure
Source
Timers.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Timers
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. final class BackpressureTimeout [T] extends SimpleLinearGraphStage[T]
  2. final class Completion [T] extends SimpleLinearGraphStage[T]
  3. final class DelayInitial [T] extends SimpleLinearGraphStage[T]
  4. final class Idle [T] extends SimpleLinearGraphStage[T]
  5. final class IdleInject [I, O >: I] extends GraphStage[FlowShape[I, O]]
  6. final class IdleTimeoutBidi [I, O] extends GraphStage[BidiShape[I, I, O, O]]
  7. final class Initial [T] extends SimpleLinearGraphStage[T]

Value Members

  1. object GraphStageLogicTimer extends Product with Serializable