Renamed EasyReader to SimpleReader and Idle to Idling.
diff --git a/example/example_consumer.go b/example/example_consumer.go
index 2587805..aa976e9 100644
--- a/example/example_consumer.go
+++ b/example/example_consumer.go
@@ -39,7 +39,7 @@
}
}
}
-func easyConsume(reader *disruptor.EasyReader) {
+func easyConsume(reader *disruptor.SimpleReader) {
for {
reader.Receive()
}
diff --git a/example/main.go b/example/main.go
index 1cecb3f..66ef2fc 100644
--- a/example/main.go
+++ b/example/main.go
@@ -39,7 +39,7 @@
go consume(reader)
// constant time regardless of the number of items
- // go easyConsume(disruptor.NewEasyReader(reader, NewExampleConsumerHandler()))
+ // go easyConsume(disruptor.NewSimpleReader(reader, NewExampleConsumerHandler()))
}
return disruptor.NewBarrier(readerCursors...)
diff --git a/reader.go b/reader.go
index e46e302..ae3febe 100644
--- a/reader.go
+++ b/reader.go
@@ -2,7 +2,7 @@
const (
Gating = -2
- Idle = -3
+ Idling = -3
)
type Reader struct {
@@ -28,6 +28,6 @@
} else if next <= this.writerCursor.Load() {
return next, Gating
} else {
- return next, Idle
+ return next, Idling
}
}
diff --git a/easy_reader.go b/simple_reader.go
similarity index 62%
rename from easy_reader.go
rename to simple_reader.go
index 5c1d14d..7623b6d 100644
--- a/easy_reader.go
+++ b/simple_reader.go
@@ -1,15 +1,15 @@
package disruptor
-type EasyReader struct {
+type SimpleReader struct {
reader *Reader
consumer Consumer
}
-func NewEasyReader(reader *Reader, consumer Consumer) *EasyReader {
- return &EasyReader{reader: reader, consumer: consumer}
+func NewSimpleReader(reader *Reader, consumer Consumer) *SimpleReader {
+ return &SimpleReader{reader: reader, consumer: consumer}
}
-func (this *EasyReader) Receive() int64 {
+func (this *SimpleReader) Receive() int64 {
sequence, remaining := this.reader.Receive()
if remaining >= 0 {
