diff --git a/rtmp/rtmp.go b/rtmp/rtmp.go index bdd24b5f..9b21e4da 100644 --- a/rtmp/rtmp.go +++ b/rtmp/rtmp.go @@ -86,6 +86,8 @@ func (c *client) ticker(ctx context.Context) { func (c *client) Close() { c.cancel() + + c.conn.Close() } // channel represents a stream that is sent to the server