Source.startContextPropagation

Turns a Source into a SourceWithContext which can propagate a context per element along a stream.

Source operators

Signature

def startContextPropagation[Ctx](f: Out ⇒ Ctx): SourceWithContext[Ctx, Out, Mat]

Description

Turns a Source into a SourceWithContext which can propagate a context per element along a stream. The function passed into startContextPropagation must turn elements into contexts, one context for every element.

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.