alsoTo

Attaches the given Sink to this Flow, meaning that elements that pass through this Flow will also be sent to the Sink.

Simple operators

Signature

def alsoTo(that: Graph[SinkShape[Out], _]): Repr[Out]
def alsoToMat[Mat2, Mat3](that: Graph[SinkShape[Out], Mat2])(matF: (Mat, Mat2) => Mat3): ReprMat[Out, Mat3]

Description

Attaches the given Sink to this Flow, meaning that elements that pass through this Flow will also be sent to the Sink.

emits when an element is available and demand exists both from the Sink and the downstream

backpressures when downstream or Sink backpressures

completes when upstream completes

cancels when downstream or Sink 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.