akka.stream.impl

Class Timers

java.lang.Object

akka.stream.impl.Timers

public class Timers
extends java.lang.Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Timers.BackpressureTimeout<T>
static class	Timers.Completion<T>
static class	Timers.DelayInitial<T>
static class	Timers.GraphStageLogicTimer$
static class	Timers.Idle<T>
static class	Timers.IdleInject<I,O>
static class	Timers.IdleTimeoutBidi<I,O>
static class	Timers.Initial<T>

Constructor Summary

Constructors

Constructor and Description
Timers()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

Timers

public Timers()