Correcting reference to writer cursor.
diff --git a/example/main.go b/example/main.go
index f690d4b..7a1672d 100644
--- a/example/main.go
+++ b/example/main.go
@@ -20,11 +20,11 @@
writer := disruptor.NewWriter(writerCursor, RingSize, readerBarrier)
publish(writer)
}
-func startReaders(barrier disruptor.Barrier, sequence *disruptor.Cursor) (readerCursors []*disruptor.Cursor) {
+func startReaders(writerBarrier disruptor.Barrier, writerCursor *disruptor.Cursor) (readerCursors []*disruptor.Cursor) {
for i := 0; i < MaxConsumers; i++ {
- sequence := disruptor.NewCursor()
- readerCursors = append(readerCursors, sequence)
- go consume(barrier, sequence, sequence)
+ readerCursor := disruptor.NewCursor()
+ readerCursors = append(readerCursors, readerCursor)
+ go consume(writerBarrier, writerCursor, readerCursor)
}
return readerCursors
