Function for_each 

pub fn for_each(
    target: impl Into<Participant>,
    policy: impl IntoPolicy,
) -> Result<ForEachStream>