Function hydro_std::quorum::collect_quorum
source ยท 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>)