diff --git a/internal/clientrtmp/client.go b/internal/clientrtmp/client.go
index 6a168b71..219920f6 100644
--- a/internal/clientrtmp/client.go
+++ b/internal/clientrtmp/client.go
@@ -310,6 +310,7 @@ func (c *Client) runRead() {
 
 		c.parent.OnClientClose(c)
 		<-c.terminate
+		return
 	}
 
 	writerDone := make(chan error)