public class CoupledTerminationFlow$ extends java.lang.Object
Flow.fromSinkAndSourcehowever that API does not connect the completion signals of the wrapped operators.
|Modifier and Type||Field and Description|
Static reference to the singleton instance of this Scala object.
|Constructor and Description|
|Modifier and Type||Method and Description|
Use `Flow.fromSinkAndSourceCoupledMat(..., ..., Keep.both())` instead. Since 2.5.2.
public static final CoupledTerminationFlow$ MODULE$
Flow.fromSinkAndSourcehowever couples the termination of these two operators.
|Returned Flow||Sink (
|cause: upstream (sink-side) receives completion||effect: receives completion||effect: receives cancel|
|cause: upstream (sink-side) receives error||effect: receives error||effect: receives cancel|
|cause: downstream (source-side) receives cancel||effect: completes||effect: receives cancel|
|effect: cancels upstream, completes downstream||effect: completes||cause: signals complete|
|effect: cancels upstream, errors downstream||effect: receives error||cause: signals error or throws|
|effect: cancels upstream, completes downstream||cause: cancels||effect: receives cancel|
The order in which the
out sides receive their respective completion signals is not defined, do not rely on its ordering.