diff --git a/rtmp/rtmp_sink.go b/rtmp/rtmp_sink.go
index 8575f65..9ae96e7 100644
--- a/rtmp/rtmp_sink.go
+++ b/rtmp/rtmp_sink.go
@@ -16,8 +16,9 @@ func (s *Sink) StartStreaming(_ stream.TransStream) error {
 	return s.stack.SendStreamBeginChunk()
 }
 
-func (s *Sink) StopStreaming(_ stream.TransStream) {
+func (s *Sink) StopStreaming(stream stream.TransStream) {
 	_ = s.stack.SendStreamEOFChunk()
+	s.BaseSink.StopStreaming(stream)
 }
 
 func (s *Sink) Close() {