fix on closed channel

pablodz · Jan 22, 2025 · 36c8e18 · 36c8e18
1 parent c67fa22
commit 36c8e18
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/fastaudiosocket/fastaudiosocket.go b/fastaudiosocket/fastaudiosocket.go
@@ -193,7 +193,11 @@ func (s *FastAudioSocket) streamRead(wg *sync.WaitGroup) {
 					if s.debug {
 						fmt.Printf("Failed to read packet: %v\n", err)
 					}
-					s.PacketChan <- PacketReader{Type: PacketTypeError}
+
+					select {
+					case s.PacketChan <- PacketReader{Type: PacketTypeError}:
+					default:
+					}
 					return
 				}
 				atomic.AddInt32(&s.chunkCounter, 1)