divertTo
Each upstream element will either be diverted to the given sink, or the downstream consumer according to the predicate function applied to the element.
Signature
def divertTo(that: Graph[SinkShape[Out], _], when: Out => Boolean): Repr[Out]
def divertToMat[Mat2, Mat3](that: Graph[SinkShape[Out], Mat2], when: Out => Boolean)(matF: (Mat, Mat2) => Mat3): ReprMat[Out, Mat3]
Description
Each upstream element will either be diverted to the given sink, or the downstream consumer according to the predicate function applied to the element.
emits when the chosen output stops backpressuring and there is an input element available
backpressures when the chosen output backpressures
completes when upstream completes and no output is pending
cancels when any of the downstreams cancel