Skip to main content

index_payloads

hydro_test::cluster::paxos

Function index_payloads 

Source 
pub fn index_payloads<'a, L: Location<'a> + NoTick, P: PaxosPayload>(
    p_max_slot: Optional<usize, Tick<L>, Bounded>,
    c_to_proposers: Stream<P, Tick<L>, Bounded>,
) -> Stream<(usize, P), Tick<L>, Bounded>