final class BidiFlow[I1, O1, I2, O2, Mat] extends Graph[BidiShape[I1, O1, I2, O2], Mat]
- Alphabetic
- By Inheritance
- BidiFlow
- Graph
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new BidiFlow(delegate: scaladsl.BidiFlow[I1, O1, I2, O2, Mat])
Type Members
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (BidiFlow[I1, O1, I2, O2, Mat], B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
addAttributes(attr: Attributes): BidiFlow[I1, O1, I2, O2, Mat]
Add the given attributes to this Source.
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asScala: scaladsl.BidiFlow[I1, O1, I2, O2, Mat]
-
def
async(dispatcher: String, inputBufferSize: Int): BidiFlow[I1, O1, I2, O2, Mat]
Put an asynchronous boundary around this
Flow
-
def
async(dispatcher: String): BidiFlow[I1, O1, I2, O2, Mat]
Put an asynchronous boundary around this
Flow
-
def
async: BidiFlow[I1, O1, I2, O2, Mat]
Put an asynchronous boundary around this
Flow
-
def
atop[OO1, II2, Mat2, M](bidi: BidiFlow[O1, OO1, II2, I2, Mat2], combine: Function2[Mat, Mat2, M]): BidiFlow[I1, OO1, II2, O2, M]
Add the given BidiFlow as the next step in a bidirectional transformation 161
Add the given BidiFlow as the next step in a bidirectional transformation 161
pipeline. By convention protocol stacks are growing to the left: the right most is the bottom layer, the closest to the metal.
+----------------------------+ | Resulting BidiFlow | | | | +------+ +------+ | I1 ~~> | | ~O1~> | | ~~> OO1 | | this | | bidi | | O2 <~~ | | <~I2~ | | <~~ II2 | +------+ +------+ | +----------------------------+
The
combine
function is used to compose the materialized values of this flow and that flow into the materialized value of the resulting BidiFlow. -
def
atop[OO1, II2, Mat2](bidi: BidiFlow[O1, OO1, II2, I2, Mat2]): BidiFlow[I1, OO1, II2, O2, Mat]
Add the given BidiFlow as the next step in a bidirectional transformation pipeline.
Add the given BidiFlow as the next step in a bidirectional transformation pipeline. By convention protocol stacks are growing to the left: the right most is the bottom layer, the closest to the metal.
+----------------------------+ | Resulting BidiFlow | | | | +------+ +------+ | I1 ~~> | | ~O1~> | | ~~> OO1 | | this | | bidi | | O2 <~~ | | <~I2~ | | <~~ II2 | +------+ +------+ | +----------------------------+
The materialized value of the combined BidiFlow will be the materialized value of the current flow (ignoring the other BidiFlow’s value), use atopMat if a different strategy is needed.
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
- def ensuring(cond: (BidiFlow[I1, O1, I2, O2, Mat]) ⇒ Boolean, msg: ⇒ Any): BidiFlow[I1, O1, I2, O2, Mat]
- def ensuring(cond: (BidiFlow[I1, O1, I2, O2, Mat]) ⇒ Boolean): BidiFlow[I1, O1, I2, O2, Mat]
- def ensuring(cond: Boolean, msg: ⇒ Any): BidiFlow[I1, O1, I2, O2, Mat]
- def ensuring(cond: Boolean): BidiFlow[I1, O1, I2, O2, Mat]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
join[Mat2, M](flow: Flow[O1, I2, Mat2], combine: Function2[Mat, Mat2, M]): Flow[I1, O2, M]
Add the given Flow as the final step in a bidirectional transformation pipeline.
Add the given Flow as the final step in a bidirectional transformation pipeline. By convention protocol stacks are growing to the left: the right most is the bottom layer, the closest to the metal.
+---------------------------+ | Resulting Flow | | | | +------+ +------+ | I1 ~~> | | ~O1~> | | | | | this | | flow | | O2 <~~ | | <~I2~ | | | | +------+ +------+ | +---------------------------+
The
combine
function is used to compose the materialized values of this flow and that flow into the materialized value of the resulting Flow. -
def
join[Mat2](flow: Flow[O1, I2, Mat2]): Flow[I1, O2, Mat]
Add the given Flow as the final step in a bidirectional transformation pipeline.
Add the given Flow as the final step in a bidirectional transformation pipeline. By convention protocol stacks are growing to the left: the right most is the bottom layer, the closest to the metal.
+---------------------------+ | Resulting Flow | | | | +------+ +------+ | I1 ~~> | | ~O1~> | | | | | this | | flow | | O2 <~~ | | <~I2~ | | | | +------+ +------+ | +---------------------------+
The materialized value of the combined Flow will be the materialized value of the current flow (ignoring the other Flow’s value), use joinMat if a different strategy is needed.
-
def
mapMaterializedValue[Mat2](f: Function[Mat, Mat2]): BidiFlow[I1, O1, I2, O2, Mat2]
Transform only the materialized value of this BidiFlow, leaving all other properties as they were.
-
def
named(name: String): BidiFlow[I1, O1, I2, O2, Mat]
Add a
attribute to this Flow.name
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
reversed: BidiFlow[I2, O2, I1, O1, Mat]
Turn this BidiFlow around by 180 degrees, logically flipping it upside down in a protocol stack.
-
def
shape: BidiShape[I1, O1, I2, O2]
The shape of a graph is all that is externally visible: its inlets and outlets.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
traversalBuilder: TraversalBuilder
INTERNAL API.
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
withAttributes(attr: Attributes): BidiFlow[I1, O1, I2, O2, Mat]
Change the attributes of this Source to the given ones and seal the list of attributes.
Change the attributes of this Source to the given ones and seal the list of attributes. This means that further calls will not be able to remove these attributes, but instead add new ones. Note that this operation has no effect on an empty Flow (because the attributes apply only to the contained processing operators).
- def →[B](y: B): (BidiFlow[I1, O1, I2, O2, Mat], B)