public class ExposeAttributes<T,U>
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<T,U>>
implements scala.Product, java.io.Serializable
Constructor and Description |
---|
ExposeAttributes(scala.Function1<org.apache.pekko.stream.Attributes,scala.Function1<T,U>> functionConstructor) |
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.stream.stage.GraphStageLogic |
createLogic(org.apache.pekko.stream.Attributes inheritedAttributes) |
scala.Function1<org.apache.pekko.stream.Attributes,scala.Function1<T,U>> |
functionConstructor() |
org.apache.pekko.stream.Inlet<T> |
in() |
org.apache.pekko.stream.Outlet<U> |
out() |
org.apache.pekko.stream.FlowShape<T,U> |
shape() |
createLogicAndMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait