diff --git a/client.go b/client.go
index 0bb1e66..27010e7 100644
--- a/client.go
+++ b/client.go
@@ -165,6 +165,9 @@ func (client *RTSPClient) pullStream() {
 		Printf("connect:%s error:%v", client.URL, err)
 		return
 	}
+	client.OnClose = func() {
+		client.Client.Close()
+	}
 	//client.close should be after connected!
 	defer client.Client.Close()
 	var res *base.Response