Timers.BackpressureTimeout

java.lang.Object
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
- - akka.stream.stage.GraphStage<FlowShape<T,T>>
  - - akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage<T>
    - - akka.stream.impl.Timers.BackpressureTimeout<T>

All Implemented Interfaces:: Graph<FlowShape<T,T>,NotUsed>

Enclosing class:: Timers

public static final class Timers.BackpressureTimeout<T>
extends GraphStages.SimpleLinearGraphStage<T>

Constructor Summary

Constructors
Constructor Description

BackpressureTimeout(scala.concurrent.duration.FiniteDuration timeout)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`GraphStageLogic`	`createLogic(Attributes inheritedAttributes)`
`Attributes`	`initialAttributes()`
`scala.concurrent.duration.FiniteDuration`	`timeout()`
`java.lang.String`	`toString()`

Methods inherited from class akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage
in, out, shape

Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.stream.Graph
addAttributes, async, async, async, named

Constructor Detail

BackpressureTimeout

public BackpressureTimeout(scala.concurrent.duration.FiniteDuration timeout)

Method Detail
- createLogic
```
public GraphStageLogic createLogic(Attributes inheritedAttributes)
```
  Specified by:
  
  createLogic in class GraphStage<FlowShape<T,T>>
- initialAttributes
```
public Attributes initialAttributes()
```
  Overrides:
  
  initialAttributes in class GraphStageWithMaterializedValue<FlowShape<T,T>,NotUsed>
- timeout
```
public scala.concurrent.duration.FiniteDuration timeout()
```
- toString
```
public java.lang.String toString()
```
  Overrides:
  
  toString in class java.lang.Object