Function grouped_multithreaded_merge

pub fn grouped_multithreaded_merge<T: MergableStreams>(
    array: Vec<impl Iterator<Item = T::Item> + Send + 'static>,
) -> impl Iterator<Item = T::Item>