Constant WATCH_BATCH_CAP 

const WATCH_BATCH_CAP: usize = 1024;

Upper bound on events coalesced into one pass, so a sustained writer cannot starve the cancel check at the top of the loop.