Contextualizing Stream Execution

Ensure flow downstream collectors run on the correct dispatchers without losing data context.