fix nits

piotrpio · piotrpio · commit 0f1fce7dbd77 · 2026-03-26T17:02:40.000+01:00
Signed-off-by: Piotr Piotrowski &lt;piotr@synadia.com&gt;
diff --git a/jetstreamext/fastpublish.go b/jetstreamext/fastpublish.go
@@ -593,7 +593,7 @@ func (fp *fastPublisher) ackMsgHandler(msg *nats.Msg) {
 			return
 		}
 		if fp.errHandler != nil {
-			fp.errHandler(fmt.Errorf("Error processing batch at sequence %d: %w", flowErr.Sequence, flowErr.Error))
+			fp.errHandler(fmt.Errorf("error processing batch at sequence %d: %w", flowErr.Sequence, flowErr.Error))
 		}
 		return
 	default:
diff --git a/jetstreamext/test/fastpublish_test.go b/jetstreamext/test/fastpublish_test.go
@@ -162,7 +162,7 @@ func TestFastPublisher(t *testing.T) {
 		}
 
 		if ack.BatchSize != 201 {
-			t.Fatalf("Expected BatchAck.BatchSize to be 21, got %d", ack.BatchSize)
+			t.Fatalf("Expected BatchAck.BatchSize to be 201, got %d", ack.BatchSize)
 		}
 	})
 

Original file line number	Diff line number	Diff line change
`@@ -593,7 +593,7 @@ func (fp fastPublisher) ackMsgHandler(msg nats.Msg) {`
`593`	`593`	`return`
`594`	`594`	`}`
`595`	`595`	`if fp.errHandler != nil {`
`596`		`- fp.errHandler(fmt.Errorf("Error processing batch at sequence %d: %w", flowErr.Sequence, flowErr.Error))`
	`596`	`+ fp.errHandler(fmt.Errorf("error processing batch at sequence %d: %w", flowErr.Sequence, flowErr.Error))`
`597`	`597`	`}`
`598`	`598`	`return`
`599`	`599`	`default:`
Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ func TestFastPublisher(t *testing.T) {`
`162`	`162`	`}`
`163`	`163`
`164`	`164`	`if ack.BatchSize != 201 {`
`165`		`- t.Fatalf("Expected BatchAck.BatchSize to be 21, got %d", ack.BatchSize)`
	`165`	`+ t.Fatalf("Expected BatchAck.BatchSize to be 201, got %d", ack.BatchSize)`
`166`	`166`	`}`
`167`	`167`	`})`
`168`	`168`