wireTap
Attaches the given Sink
to this Flow
as a wire tap, meaning that elements that pass through will also be sent to the wire-tap Sink
, without the latter affecting the mainline flow.
Signature
def wireTap(f: Out => Unit): Repr[Out]
def wireTap(that: Graph[SinkShape[Out], _]): Repr[Out]
def wireTapMat[Mat2, Mat3](that: Graph[SinkShape[Out], Mat2])(matF: (Mat, Mat2) => Mat3): ReprMat[Out, Mat3]
Description
Attaches the given Sink
to this Flow
as a wire tap, meaning that elements that pass through will also be sent to the wire-tap Sink
, without the latter affecting the mainline flow. If the wire-tap Sink
backpressures, elements that would’ve been sent to it will be dropped instead.
emits element is available and demand exists from the downstream; the element will also be sent to the wire-tap Sink
if there is demand.
backpressures downstream backpressures
completes upstream completes
cancels downstream cancels