Put the Manager in its own package

1 files changed, 0 insertions, 46 deletions

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()
-}