Struct FanOut 

pub struct FanOut {
    pub context: HashMap<String, String>,
}

Distributes a single input context to N parallel tasks.

FanOut owns the initial context key-value pairs that will be passed (via Arc) to every spawned task.

Fields

context: HashMap<String, String>

Shared context forwarded to all tasks.

Implementations

impl FanOut

pub fn new() -> Self

Create an empty fan-out context.

pub fn insert( &mut self, key: impl Into<String>, value: impl Into<String>, ) -> &mut Self

Insert a key-value pair into the shared context.

pub fn with(self, key: impl Into<String>, value: impl Into<String>) -> Self

Builder-style context insertion.

Trait Implementations

impl Clone for FanOut

fn clone(&self) -> FanOut

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FanOut

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FanOut

fn default() -> FanOut

Returns the “default value” for a type.