From 5147048d4a67c59f799203e1cc5f79b183208cab Mon Sep 17 00:00:00 2001 From: Silvan Jegen Date: Wed, 15 Feb 2017 12:55:58 +0100 Subject: Put the Manager in its own package --- manager.go | 46 ---------------------------------------------- 1 file changed, 46 deletions(-) delete mode 100644 manager.go (limited to 'manager.go') diff --git a/manager.go b/manager.go deleted file mode 100644 index d3d38fd..0000000 --- a/manager.go +++ /dev/null @@ -1,46 +0,0 @@ -package main - -import ( - "fmt" - "sync" - - "github.com/Shugyousha/stasher/filter" - "github.com/Shugyousha/stasher/input" - "github.com/Shugyousha/stasher/output" - "github.com/Shugyousha/stasher/work" -) - -type Manager struct { - Input input.Input - Filter filter.Filter - Output output.Output -} - -func (m *Manager) Run() { - var wg sync.WaitGroup - - ic := m.Input.Start() - for w := range ic { - if w.Err != nil { - fmt.Printf("Got an error when getting Work input: %q\n", w.Err) - continue - } - wg.Add(1) - - go func(w *work.Work) { - nw := m.Filter.Filter(w) - err := nw.Error() - if err != nil { - fmt.Printf("Got an error when filtering Work: %q\n", err) - } - err = m.Output.Output(nw) - if err != nil { - fmt.Printf("Got an error when outputting Work: %q\n", err) - } - - wg.Done() - }(w) - } - - wg.Wait() -} -- cgit v1.2.1-18-gbd029