Function collect_quorum_with_response 

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