fix watcher api errors

playnet-public · Sep 11, 2018 · f395876 · f395876
1 parent 1779a50
commit f395876
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/pkg/watcher/watcher.go b/pkg/watcher/watcher.go
@@ -71,7 +71,7 @@ func (w *Watcher) Start(ctx context.Context) error {
 	})
 
 	w.Process.SetOut(stderr, stdout)
-	w.Tomb.Go(w.Process.Start)
+	w.Tomb.Go(w.Process.Run)
 	w.Tomb.Go(func() error {
 		w.TLock.RLock()
 		defer w.TLock.RUnlock()

diff --git a/pkg/watcher/watcher_test.go b/pkg/watcher/watcher_test.go
@@ -51,10 +51,10 @@ var _ = Describe("Watcher", func() {
 		It("does start process", func() {
 			w.Start(ctx)
 			time.Sleep(100 * time.Millisecond)
-			Expect(p.StartCallCount()).To(BeEquivalentTo(1))
+			Expect(p.RunCallCount()).To(BeEquivalentTo(1))
 		})
 		It("does end OutputHandlers on tomb dying", func() {
-			p.StartReturns(nil)
+			p.RunReturns(nil)
 			w.Start(ctx)
 			time.Sleep(100 * time.Millisecond)
 			w.TLock.RLock()