From 03d6ae7d3b6d55c2836ab608c23f401b19215648 Mon Sep 17 00:00:00 2001
From: Ben Grewell <BGrewell@gmail.com>
Date: Wed, 10 Mar 2021 14:06:57 -0800
Subject: [PATCH] close reporting channel

---
 .idea/workspace.xml | 1 -
 reporter_linux.go   | 3 ++-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 1c5f0c4..7aa60f7 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -3,7 +3,6 @@
   <component name="ChangeListManager">
     <list default="true" id="fc2840de-29dc-4fca-8e0e-a283562f60ca" name="Default Changelist" comment="">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/client.go" beforeDir="false" afterPath="$PROJECT_DIR$/client.go" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/reporter_linux.go" beforeDir="false" afterPath="$PROJECT_DIR$/reporter_linux.go" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
diff --git a/reporter_linux.go b/reporter_linux.go
index adc6106..b12a515 100644
--- a/reporter_linux.go
+++ b/reporter_linux.go
@@ -57,7 +57,6 @@ func (r *Reporter) runLogProcessor() {
 	}
 	for line := range tailer.Lines {
 		// TODO: For now this only cares about individual streams it ignores the sum lines
-		fmt.Println(line.Text)
 		if len(line.Text) > 5 {
 			id := line.Text[1:4]
 			stream, err := strconv.Atoi(strings.TrimSpace(id))
@@ -116,6 +115,8 @@ func (r *Reporter) runLogProcessor() {
 		}
 
 		if !r.running {
+			fmt.Println("reporter is finished. exiting")
+			close(r.ReportingChannel)
 			return
 		}
 	}