public static final class GraphStages.TickSource<T> extends GraphStageWithMaterializedValue<SourceShape<T>,Cancellable>
Constructor and Description |
---|
TickSource(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration interval,
T tick) |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<GraphStageLogic,Cancellable> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Attributes |
initialAttributes() |
scala.concurrent.duration.FiniteDuration |
initialDelay() |
scala.concurrent.duration.FiniteDuration |
interval() |
Outlet<T> |
out() |
SourceShape<T> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
T |
tick() |
java.lang.String |
toString() |
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public TickSource(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration interval, T tick)
public scala.concurrent.duration.FiniteDuration initialDelay()
public scala.concurrent.duration.FiniteDuration interval()
public T tick()
public SourceShape<T> shape()
Graph
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<SourceShape<T>,Cancellable>
public scala.Tuple2<GraphStageLogic,Cancellable> createLogicAndMaterializedValue(Attributes inheritedAttributes)
createLogicAndMaterializedValue
in class GraphStageWithMaterializedValue<SourceShape<T>,Cancellable>
public java.lang.String toString()
toString
in class java.lang.Object