Function hydro_std::quorum::collect_quorum_with_response

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