Golang port of underscore.js

debounce.go

func debounceChannel(interval time.Duration, output chan int) chan int {
  input := make(chan int)

  go func() {
    var buffer int
    var ok bool

    // We do not start waiting for interval until called at least once
    buffer, ok = <-input 
    // If channel closed exit, we could also close output
    if !ok {
      return
    }
    
    // We start waiting for an interval
    for {
      select {
      case buffer, ok = <-input:
        // If channel closed exit, we could also close output
        if !ok {
          return
        }

      case <-time.After(interval):
        // Interval has passed and we have data, so send it
        output <- buffer
        // Wait for data again before starting waiting for an interval
        buffer, ok = <-input
        if !ok {
          return
        }
        // If channel is not closed we have more data and start waiting for interval
      }
    }
  }()

  return input
}

func debounce(interval time.Duration, f func()) func() {

	var timer *time.Timer
	var v atomic.Value
	v.Store(timer)
	return func() {
		swapped := v.CompareAndSwap((*time.Timer)(nil), time.NewTimer(interval))
		if swapped {
			go func() {
				timerr := (v.Load()).(*time.Timer)
				<-timerr.C
				timerr.Stop()
				v.Store((*time.Timer)(nil))
				f()
			}()
		} else {
			return
		}

	}
}