Function kv_replica

pub fn kv_replica<'a, K: KvKey, V: KvValue>(
    replicas: &Cluster<'a, Replica>,
    p_to_replicas: impl Into<Stream<(usize, Option<KvPayload<K, V>>), Cluster<'a, Replica>, Unbounded, NoOrder>>,
    checkpoint_frequency: usize,
) -> (Stream<usize, Cluster<'a, Replica>, Unbounded>, Stream<KvPayload<K, V>, Cluster<'a, Replica>, Unbounded>)