counter.go

type Counter struct {
	Write  uint
	Read   uint
	stream chan uint
	inLoop bool
}

func NewCounter(wi, ri uint) *Counter {
	c := &Counter{Write: wi, Read: ri}
	c.stream = make(chan uint)
	go c.Loop()
	return c
}

func (c *Counter) Incr() {
	c.Write++
	if !c.inLoop {
		c.inLoop = true
		go c.Loop()
	}
}

func (c *Counter) Next() uint {
	return <-c.stream
}

func (c *Counter) Distance() uint {
	return c.Write - c.Read
}

func (c *Counter) Loop() {
	for c.Write > c.Read {
		c.stream <- c.Read + 1
		c.Read++
	}
	c.inLoop = false
}