From 9c2f520627f723f4cbac9bef4e1f49ab2d3776cc Mon Sep 17 00:00:00 2001
From: jjpinto <jorgpinto@gmail.com>
Date: Fri, 23 Jan 2026 23:21:24 -0500
Subject: [PATCH] Update doc comments, invalid example

---
 _examples/basic/4-metrics/main.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/_examples/basic/4-metrics/main.go b/_examples/basic/4-metrics/main.go
index d50a0d43b..a5084cdbb 100644
--- a/_examples/basic/4-metrics/main.go
+++ b/_examples/basic/4-metrics/main.go
@@ -33,7 +33,7 @@ func delay() {
 	time.Sleep(time.Duration(float64(time.Second) * delay))
 }
 
-// handler publishes 0-4 messages with a random delay.
+// handler publishes 0–3 messages after a random delay.
 func handler(msg *message.Message) ([]*message.Message, error) {
 	delay()
 
@@ -46,7 +46,7 @@ func handler(msg *message.Message) ([]*message.Message, error) {
 	return outgoing, nil
 }
 
-// consumeMessages consumes the messages exiting the handler.
+// consumeMessages consumes messages published by the handler.
 func consumeMessages(subscriber message.Subscriber) {
 	messages, err := subscriber.Subscribe(context.Background(), "pub_topic")
 	if err != nil {
@@ -58,7 +58,7 @@ func consumeMessages(subscriber message.Subscriber) {
 	}
 }
 
-// produceMessages produces the incoming messages in delays of 50-100 milliseconds.
+// produceMessages generates incoming messages with delays of 50–100 milliseconds.
 func produceMessages(routerClosed chan struct{}, publisher message.Publisher) {
 	for {
 		select {
@@ -115,7 +115,7 @@ func main() {
 	// The handler's publisher and subscriber will be decorated by `AddPrometheusRouterMetrics`.
 	// We are using the same pub/sub to generate messages incoming to the handler
 	// and consume the outgoing messages.
-	// They will have `handler_name=<no handler>` label in Prometheus.
+	// These will have the label handler_name=<no handler> in Prometheus.
 	subWithMetrics, err := metricsBuilder.DecorateSubscriber(pubSub)
 	if err != nil {
 		panic(err)