Producing a single item has huge effect on latency.
diff --git a/example/example_consumer.go b/example/example_consumer.go
index f4f64f9..9658753 100644
--- a/example/example_consumer.go
+++ b/example/example_consumer.go
@@ -24,10 +24,10 @@
started = time.Now()
}
- // if sequence != ringBuffer[sequence&RingMask] {
- // message := ringBuffer[sequence&RingMask]
- // panic(fmt.Sprintf("Sequence: %d, Message %d\n", sequence, message))
- // }
+ if sequence != ringBuffer[sequence&RingMask] {
+ message := ringBuffer[sequence&RingMask]
+ panic(fmt.Sprintf("Sequence: %d, Message %d\n", sequence, message))
+ }
remaining--
sequence++