diff --git a/server/stream.go b/server/stream.go index 6a9f6206..d03306d7 100644 --- a/server/stream.go +++ b/server/stream.go @@ -842,7 +842,7 @@ func (mset *stream) clearCLFS() uint64 { mset.mu.Lock() defer mset.mu.Unlock() clfs := mset.clfs - mset.clfs = 0 + mset.clfs, mset.clseq = 0, 0 return clfs }