[FIXED] Invalid PullExpiry validation (#1468)

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
nats-io · Nov 11, 2023 · e41d5ce · e41d5ce
1 parent f214371
commit e41d5ce
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/jetstream/options.go b/jetstream/options.go
@@ -122,7 +122,7 @@ type PullExpiry time.Duration
 
 func (exp PullExpiry) configureConsume(opts *consumeOpts) error {
 	expiry := time.Duration(exp)
-	if expiry < 1*time.Second {
+	if expiry < time.Second {
 		return fmt.Errorf("%w: expires value must be at least 1s", ErrInvalidOption)
 	}
 	opts.Expires = expiry
@@ -131,7 +131,7 @@ func (exp PullExpiry) configureConsume(opts *consumeOpts) error {
 
 func (exp PullExpiry) configureMessages(opts *consumeOpts) error {
 	expiry := time.Duration(exp)
-	if expiry < 0 {
+	if expiry < time.Second {
 		return fmt.Errorf("%w: expires value must be at least 1s", ErrInvalidOption)
 	}
 	opts.Expires = expiry