From 6dd2e9a49acde23dcf5e9701915f7e8ed692ce5a Mon Sep 17 00:00:00 2001 From: Tibor Vass Date: Wed, 29 Jan 2014 14:50:31 -0800 Subject: gofmt all go code --- watcher/batcher.go | 112 ++++++++++++++++++++++++++--------------------------- 1 file changed, 56 insertions(+), 56 deletions(-) (limited to 'watcher') 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() +} -- cgit v1.2.3