pub async fn wait_for_integration_diff_conditional(
cells: &[(&AgentPubKey, &DhtStoreRead, Option<&DhtStoreRead>)],
timeout: Duration,
conditions: ConsistencyConditions,
) -> ConsistencyResultExpand description
Wait for all cell envs to reach consistency, meaning that every op published by every cell has been integrated by every node.
Each cell is (author, authored_store, online_dht_store). The published
set is read from each cell’s own DHT store (self-authored ops), and the
integrated set from each online cell’s DHT store. Cells with None for the
DHT store are treated as offline: their published ops still count towards
the total, but their integration is not checked.