Fix leftover change from debugging

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
nats-io · Oct 12, 2023 · 79f1255 · 79f1255
1 parent 07328c7
commit 79f1255
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/jetstream/ordered.go b/jetstream/ordered.go
@@ -133,7 +133,7 @@ func (c *orderedConsumer) Consume(handler MessageHandler, opts ...PullConsumeOpt
 				if c.withStopAfter {
 					select {
 					case c.stopAfter = <-c.stopAfterMsgsLeft:
-					case <-time.After(1 * time.Second):
+					default:
 					}
 					if c.stopAfter <= 0 {
 						sub.Stop()