gofmt all go code

1 files changed, 56 insertions, 56 deletions

diff --git a/watcher/batcher.go b/watcher/batcher.go
index a22ad8b41..7e9ce8861 100644
--- a/watcher/batcher.go
+++ b/watcher/batcher.go
@@ -1,56 +1,56 @@
-package watcher

-

-import (

-	"github.com/howeyc/fsnotify"

-	"time"

-)

-

-type Batcher struct {

-	*fsnotify.Watcher

-	interval time.Duration

-	done     chan struct{}

-

-	Event chan []*fsnotify.FileEvent // Events are returned on this channel

-}

-

-func New(interval time.Duration) (*Batcher, error) {

-	watcher, err := fsnotify.NewWatcher()

-

-	batcher := &Batcher{}

-	batcher.Watcher = watcher

-	batcher.interval = interval

-	batcher.done = make(chan struct{}, 1)

-	batcher.Event = make(chan []*fsnotify.FileEvent, 1)

-

-	if err == nil {

-		go batcher.run()

-	}

-

-	return batcher, err

-}

-

-func (b *Batcher) run() {

-	tick := time.Tick(b.interval)

-	evs := make([]*fsnotify.FileEvent, 0)

-OuterLoop:

-	for {

-		select {

-		case ev := <-b.Watcher.Event:

-			evs = append(evs, ev)

-		case <-tick:

-			if len(evs) == 0 {

-				continue

-			}

-			b.Event <- evs

-			evs = make([]*fsnotify.FileEvent, 0)

-		case <-b.done:

-			break OuterLoop

-		}

-	}

-	close(b.done)

-}

-

-func (b *Batcher) Close() {

-	b.done <- struct{}{}

-	b.Watcher.Close()

-}

+package watcher
+
+import (
+	"github.com/howeyc/fsnotify"
+	"time"
+)
+
+type Batcher struct {
+	*fsnotify.Watcher
+	interval time.Duration
+	done     chan struct{}
+
+	Event chan []*fsnotify.FileEvent // Events are returned on this channel
+}
+
+func New(interval time.Duration) (*Batcher, error) {
+	watcher, err := fsnotify.NewWatcher()
+
+	batcher := &Batcher{}
+	batcher.Watcher = watcher
+	batcher.interval = interval
+	batcher.done = make(chan struct{}, 1)
+	batcher.Event = make(chan []*fsnotify.FileEvent, 1)
+
+	if err == nil {
+		go batcher.run()
+	}
+
+	return batcher, err
+}
+
+func (b *Batcher) run() {
+	tick := time.Tick(b.interval)
+	evs := make([]*fsnotify.FileEvent, 0)
+OuterLoop:
+	for {
+		select {
+		case ev := <-b.Watcher.Event:
+			evs = append(evs, ev)
+		case <-tick:
+			if len(evs) == 0 {
+				continue
+			}
+			b.Event <- evs
+			evs = make([]*fsnotify.FileEvent, 0)
+		case <-b.done:
+			break OuterLoop
+		}
+	}
+	close(b.done)
+}
+
+func (b *Batcher) Close() {
+	b.done <- struct{}{}
+	b.Watcher.Close()
+}