Parallelized version of our counter.

rayon.rs

/// Computes the flux over the provided input byte string.
fn flux_over_byte_string<T>(input: T) -> Option<Flux>
where
    T: AsRef<[u8]> {
    input.as_ref()
        .par_iter()
        .cloned()
        .map(Flux::from)
        .fold(|| None, |acc, next| span_opt(acc, Some(next)))
        .reduce(|| None, |acc, next| span_opt(acc, next))
}