Exit on read err

cmoog · cmoog · commit 0613cfe9a4ac · 2020-06-16T16:20:01.000-05:00
diff --git a/client.go b/client.go
@@ -166,7 +166,7 @@ func (r remoteProcess) listen(ctx context.Context) {
 		for ctx.Err() == nil {
 			_, payload, err := r.conn.Read(ctx)
 			if err != nil {
-				continue
+				return err
 			}
 			headerByt, body := proto.SplitMessage(payload)
 

Original file line number	Diff line number	Diff line change
`@@ -166,7 +166,7 @@ func (r remoteProcess) listen(ctx context.Context) {`
`166`	`166`	`for ctx.Err() == nil {`
`167`	`167`	`_, payload, err := r.conn.Read(ctx)`
`168`	`168`	`if err != nil {`
`169`		`- continue`
	`169`	`+ return err`
`170`	`170`	`}`
`171`	`171`	`headerByt, body := proto.SplitMessage(payload)`
`172`	`172`