Return `true` if `op_hlc` has not yet been delivered to the subscriber. An op is eligible when `op_hlc > last_pushed_hlc`, i.e. it arrived after the subscriber's watermark. The HLC's total ordering (physical_ms, logical, replica_id) guarantees this is correct under any clock skew.
(op_hlc: Hlc, last_pushed_hlc: Hlc)
| 17 | /// The HLC's total ordering (physical_ms, logical, replica_id) guarantees |
| 18 | /// this is correct under any clock skew. |
| 19 | pub fn should_send(op_hlc: Hlc, last_pushed_hlc: Hlc) -> bool { |
| 20 | op_hlc > last_pushed_hlc |
| 21 | } |
| 22 | |
| 23 | /// Advance the subscriber cursor to `op_hlc` and persist. |
| 24 | /// |