public static final class Timed.TimedInterval<T> extends GraphStages.SimpleLinearGraphStage<T>
Constructor and Description |
---|
TimedInterval(scala.Function1<T,java.lang.Object> matching,
scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval) |
Modifier and Type | Method and Description |
---|---|
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
in, out, shape
createLogicAndMaterializedValue
initialAttributes, module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public TimedInterval(scala.Function1<T,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<FlowShape<T,T>>