diff options
author | Silvan Jegen <s.jegen@gmail.com> | 2017-01-18 18:22:16 +0100 |
---|---|---|
committer | Silvan Jegen <s.jegen@gmail.com> | 2017-01-18 18:22:16 +0100 |
commit | 76e2175159ac2ff4b26d2606f4d8f1d7a896c5cc (patch) | |
tree | 3864cce33beb8bd851374df2d735831c8cfe3a23 /manager.go | |
parent | c003fdf2182432a25892467bf1a456049f4b1c1d (diff) |
Rename file
Diffstat (limited to 'manager.go')
-rw-r--r-- | manager.go | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/manager.go b/manager.go new file mode 100644 index 0000000..3fd2234 --- /dev/null +++ b/manager.go @@ -0,0 +1,39 @@ +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 { + 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 processing Work: %q\n", err) + } + m.Output.Output(nw) + + wg.Done() + }(w) + } + + wg.Wait() +} |