Added guard in case of broken pipe for streaming (#11)

README.md

@@ -115,6 +115,10 @@ loggo stream --file <my file> --template <my template yaml>
 ````
 tail -f <my file> | loggo stream
 ````
+Kubernetes example:
+````
+kubectl logs -f -n <namespace> <pod> | loggo stream
+````
 *With Template:*
 ````
 tail -f <my file> | loggo stream --template <my template yaml>

internal/reader/pipe_reader.go

@@ -26,6 +26,7 @@ import (
 	"bufio"
 	"fmt"
 	"os"
+	"time"
 )
 
 type readPipeStream struct {
@@ -49,7 +50,7 @@ func (s *readPipeStream) StreamInto(strChan chan<- string) error {
 		for !s.stop {
 			str, err := reader.ReadString('\n')
 			if err != nil {
-				panic(err)
+				time.Sleep(time.Second)
 			}
 			strChan <- str
 		}

internal/uitest/streamer/main_streamer.go

@@ -0,0 +1,22 @@
+package main
+
+import (
+	"fmt"
+
+	"github.com/aurc/loggo/internal/reader"
+)
+
+func main() {
+	streamReader := reader.MakeReader("")
+	streamReceiver := make(chan string, 1)
+	go streamReader.StreamInto(streamReceiver)
+	for {
+		line, ok := <-streamReceiver
+		if !ok {
+			break
+		}
+		if len(line) > 0 {
+			fmt.Printf("READER: %s", line)
+		}
+	}
+}