Made Counter less complex

counter.go

@@ -1,6 +1,8 @@
 package main
 
-import ()
+import (
+	"sync"
+)
 
 const (
 	MaxIndex = ^uint(0)
@@ -8,44 +10,57 @@ const (
 
 type (
 	Counter struct {
-		Write  uint
+		WriteIndex uint
-		Read   uint
+		ReadIndex  uint
-		stream chan uint
+		mutex      sync.Mutex
-		inLoop bool
+		stream     chan uint
+		streaming  bool
 	}
 )
 
-func NewCounter(wi, ri uint) *Counter {
+func NewCounter(wi, ri uint) Counter {
-	c := &Counter{Write: wi, Read: ri}
+	c := Counter{
-	c.stream = make(chan uint)
+		WriteIndex: wi,
-	go c.Loop()
+		ReadIndex:  ri,
+		stream:     make(chan uint),
+		streaming:  false,
+	}
+	if c.Distance() > 0 {
+		go c.Stream()
+	}
 	return c
 }
 
-func (c *Counter) Incr() {
+func (c *Counter) Write(proc func(i uint) bool) {
-	c.Write++
+	c.mutex.Lock()
-	if !c.inLoop {
+	defer c.mutex.Unlock()
-		c.inLoop = true
+
-		go c.Loop()
+	ok := proc(c.WriteIndex + 1)
+	if ok {
+		c.WriteIndex++
+		if !c.streaming {
+			go c.Stream()
+		}
 	}
 }
 
-func (c *Counter) Next() uint {
+func (c *Counter) Read() uint {
 	return <-c.stream
 }
 
 func (c *Counter) Distance() uint {
-	d := c.Write - c.Read
+	d := c.WriteIndex - c.ReadIndex
 	if d < 0 {
 		d += MaxIndex
 	}
 	return d
 }
 
-func (c *Counter) Loop() {
+func (c *Counter) Stream() {
-	for c.Write > c.Read {
+	c.streaming = true
-		c.stream <- c.Read + 1
+	for c.WriteIndex > c.ReadIndex {
-		c.Read++
+		c.stream <- c.ReadIndex + 1
+		c.ReadIndex++
 	}
-	c.inLoop = false
+	c.streaming = false
 }