propagate

fun propagate(header: Header, upstream: Message<*, *>)

Runs every propagator for a message derived from upstream.


fun propagate(header: Header, upstream: Message<*, *>, producer: FunctionInfo)

Runs every propagator for a message that producer derives from upstream.