Added TODOs to reader.
diff --git a/reader.go b/reader.go
index db68058..2a39e88 100644
--- a/reader.go
+++ b/reader.go
@@ -29,7 +29,7 @@
}
func (this *Reader) receive() {
- previous := this.read.Sequence
+ previous := this.read.Sequence // TODO: this.read.Load()
idling, gating := 0, 0
for {
@@ -38,7 +38,7 @@
if lower <= upper {
this.consumer.Consume(lower, upper)
- this.read.Sequence = upper
+ this.read.Sequence = upper // TODO: this.read.Commit()
previous = upper
} else if upper = this.written.Load(); lower <= upper {
// Gating--TODO: wait strategy (provide gating count to wait strategy for phased backoff)
