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 /types.go | |
parent | c003fdf2182432a25892467bf1a456049f4b1c1d (diff) |
Rename file
Diffstat (limited to 'types.go')
-rw-r--r-- | types.go | 48 |
1 files changed, 0 insertions, 48 deletions
diff --git a/types.go b/types.go deleted file mode 100644 index abd2658..0000000 --- a/types.go +++ /dev/null @@ -1,48 +0,0 @@ -package main - -import ( - "fmt" - "sync" - - "github.com/Shugyousha/stasher/work" -) - -type Input interface { - Start() chan *work.Work -} - -type Filter interface { - Filter(*work.Work) *work.Work -} - -type Output interface { - Output(*work.Work) -} - -type Manager struct { - Input Input - Filter Filter - 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() -} |