fix(jetstream): Only call NakWithDelay() once

zapling · Nov 3, 2024 · 7e53a11 · 7e53a11
1 parent 541b0e4
commit 7e53a11
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/jetstream/jetstream.go b/jetstream/jetstream.go
@@ -112,5 +112,6 @@ func (e *responseAndEvent) NakWithDelay(delay time.Duration) error {
 	if e.responseSent {
 		return nil
 	}
+	e.responseSent = true
 	return e.m.NakWithDelay(delay)
 }