Function hydro_std::quorum::collect_quorum

pub fn collect_quorum<'a, L: Location<'a> + NoTick, Order, K: Clone + Eq + Hash, E: Clone>(
    responses: Stream<(K, Result<(), E>), Atomic<L>, Unbounded, Order>,
    min: usize,
    max: usize,
) -> (Stream<K, Atomic<L>, Unbounded, Order>, Stream<(K, E), Atomic<L>, Unbounded, Order>)