1 files changed, 4 insertions, 0 deletions
diff --git a/stdin.go b/stdin.go
index d79252e..7fadf06 100644
--- a/stdin.go
+++ b/stdin.go
@@ -22,10 +22,12 @@ func init() {
 func readFromStdin() <-chan []byte {
 	out := make(chan []byte)
 	go func() {
+		logger.Println("Now listening on stdin...")
 		scanner := bufio.NewScanner(os.Stdin)
 		for scanner.Scan() {
 			out <- []byte(scanner.Text())
 		}
+		logger.Println("Finished listening to stdin!")
 		close(out)
 	}()
 	return out
@@ -38,6 +40,7 @@ func parseRawData(in <-chan []byte, cfg *Config) <-chan []RawData {
 		logger.Println("Could not parse interval: ", err)
 	}
 	timeBin := time.Now().Add(ival / -2) //Make sure we are inside the correct timeBin
+	logger.Println("Now parsing data from stdin...")
 	go func() {
 		rDat := make([]RawData, 0)
 		for line := range in {
@@ -73,6 +76,7 @@ func parseRawData(in <-chan []byte, cfg *Config) <-chan []RawData {
 		if len(rDat) > 0 {
 			out <- rDat
 		}
+		logger.Println("Finished parsing data from stdin...")
 		close(out)
 	}()
 	return out