public class Timers
extends java.lang.Object
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
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 and Description |
---|
Timers() |