Skip to content

Commit 91421e2

Browse files
committed
close channel on serial errors
1 parent 536c0ef commit 91421e2

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

teleinfo.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,11 +64,13 @@ func StartReading(port string, mode LinkyMode) (<-chan TeleInfo, error) {
6464
frameChan := make(chan TeleInfo)
6565

6666
go func() {
67+
defer close(frameChan)
68+
6769
for {
6870
frame, err := decodeFrame(reader, mode)
6971
if err != nil {
70-
log.Error("Error in frame: ", err)
71-
continue
72+
log.Error("Error to read serial: ", err)
73+
return
7274
}
7375
frameChan <- frame
7476
}

0 commit comments

Comments
 (0)