diff --git a/pkg/depth/buffer.go b/pkg/depth/buffer.go index 30a3abd25..05ab39faa 100644 --- a/pkg/depth/buffer.go +++ b/pkg/depth/buffer.go @@ -158,7 +158,7 @@ func (b *Buffer) fetchAndPush() error { var pushUpdates []Update for _, u := range b.buffer { // skip old events - if u.FirstUpdateID < finalUpdateID+1 { + if u.FinalUpdateID <= finalUpdateID { continue }