From cf3dfc0774134a641b6bf1b35e6bbc35a1a49878 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Stephan=20M=C3=BCller?= Date: Thu, 18 Apr 2019 21:55:17 +0200 Subject: [PATCH] remove code complexity --- file.go | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/file.go b/file.go index 033babe..5ea3208 100644 --- a/file.go +++ b/file.go @@ -25,16 +25,20 @@ func getStoredDataFromFile(path string) (*StoredData, error) { return data, nil } +func sendStoredData(path string, dataCh chan *StoredData, errCh chan error) { + data, err := getStoredDataFromFile(path) + if err != nil { + errCh <- err + } + dataCh <- data +} + func (b FileBackend) loop(watch bool) (<-chan *StoredData, <-chan error) { dataCh := make(chan *StoredData) errCh := make(chan error) go func() { - data, err := getStoredDataFromFile(b.Path) - if err != nil { - errCh <- err - } - dataCh <- data + sendStoredData(b.Path, dataCh, errCh) if !watch { close(dataCh) close(errCh) @@ -58,11 +62,7 @@ func (b FileBackend) loop(watch bool) (<-chan *StoredData, <-chan error) { return } if event.Op&fsnotify.Write == fsnotify.Write { - data, err1 := getStoredDataFromFile(b.Path) - if err1 != nil { - errCh <- err1 - } - dataCh <- data + sendStoredData(b.Path, dataCh, errCh) } case err1, ok := <-watcher.Errors: if !ok {