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.

Simple operators

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

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.