public static class One2OneBidiFlow.One2OneBidi<I,O>
extends akka.stream.stage.GraphStage<akka.stream.BidiShape<I,I,O,O>>
Constructor and Description |
---|
One2OneBidi(int maxPending,
scala.Function1<java.lang.Object,java.lang.Throwable> outputTruncationException,
scala.Function1<java.lang.Object,java.lang.Throwable> unexpectedOutputException) |
Modifier and Type | Method and Description |
---|---|
akka.stream.stage.GraphStageLogic |
createLogic(akka.stream.Attributes effectiveAttributes) |
akka.stream.Inlet<O> |
fromWrapped() |
akka.stream.Inlet<I> |
in() |
akka.stream.Attributes |
initialAttributes() |
akka.stream.Outlet<O> |
out() |
akka.stream.BidiShape<I,I,O,O> |
shape() |
java.lang.String |
toString() |
akka.stream.Outlet<I> |
toWrapped() |
addAttributes, async, async, async, createLogicAndMaterializedValue, named, traversalBuilder, withAttributes
public One2OneBidi(int maxPending, scala.Function1<java.lang.Object,java.lang.Throwable> outputTruncationException, scala.Function1<java.lang.Object,java.lang.Throwable> unexpectedOutputException)
public akka.stream.stage.GraphStageLogic createLogic(akka.stream.Attributes effectiveAttributes)
public akka.stream.Inlet<O> fromWrapped()
public akka.stream.Inlet<I> in()
public akka.stream.Attributes initialAttributes()
public akka.stream.Outlet<O> out()
public java.lang.String toString()
toString
in class java.lang.Object
public akka.stream.Outlet<I> toWrapped()