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