diff --git a/client.go b/client.go
index 0983efa..0568419 100644
--- a/client.go
+++ b/client.go
@@ -100,6 +100,7 @@ func NewRTMPClient(addr string) (client *NetConnection, err error) {
 type RTMPPusher struct {
 	RTMPSender
 	engine.Pusher
+	isClientStop bool
 }
 
 func (pusher *RTMPPusher) Connect() (err error) {
@@ -157,6 +158,17 @@ func (pusher *RTMPPusher) Push() error {
 	}
 }
 
+func (pusher *RTMPPusher) OnEvent(event any) {
+	switch event.(type) {
+	case engine.SEclose:
+		pusher.isClientStop = true
+	}
+}
+
+func (pusher *RTMPPusher) IsShutdown() bool {
+	return pusher.isClientStop
+}
+
 type RTMPPuller struct {
 	RTMPReceiver
 	engine.Puller