diff --git a/subscriber.go b/subscriber.go
index 33d22da..48bb81d 100644
--- a/subscriber.go
+++ b/subscriber.go
@@ -30,8 +30,12 @@ type Subscriber struct {
 }
 
 func (s *Subscriber) close() {
-	s.UnSubscribe(s)
-	s.cancel()
+	if s.Stream != nil {
+		s.UnSubscribe(s)
+	}
+	if s.cancel != nil {
+		s.cancel()
+	}
 }
 
 // Close 关闭订阅者