diff --git a/example/main.go b/example/main.go
index fe2d052..9b3f87e 100644
--- a/example/main.go
+++ b/example/main.go
@@ -53,6 +53,8 @@
 func consume(written, read *disruptor.Cursor) {
 	sleeps := 0
 
+	consumer := SampleConsumer{}
+
 	previous := int64(-1)
 	gate := int64(-1)
 	for previous < Iterations {
@@ -62,11 +64,15 @@
 		if current <= gate {
 
 			for current < gate {
-				if ringBuffer[current&BufferMask] > 0 {
-				}
-
-				current++
+				current += consumer.Consume(current, gate)
 			}
+			// for current <= gate {
+
+			// 	if ringBuffer[current&BufferMask] > 0 {
+			// 	}
+
+			// 	current++
+			// }
 
 			previous = gate
 			read.Sequence = gate
@@ -93,3 +99,16 @@
 	// 	// read.Sequence = sequence
 	// }
 }
+
+type Consumer interface {
+	Consume(lower, upper int64)
+}
+
+type SampleConsumer struct{}
+
+func (this SampleConsumer) Consume(current, gate int64) int64 {
+	if ringBuffer[current&BufferMask] > 0 {
+	}
+
+	return 1
+}