rtmp: fix client removal after an error

5 years ago · 488b24dfe4
1 changed files with 1 additions and 0 deletions
--- a/internal/clientrtmp/client.go
+++ b/internal/clientrtmp/client.go
@ -310,6 +310,7 @@ func (c *Client) runRead() {
				@@ -310,6 +310,7 @@ func (c *Client) runRead() {

 		c.parent.OnClientClose(c)
 		<-c.terminate
+		return
 	}

 	writerDone := make(chan error)