diff --git a/netStream.go b/netStream.go
index 055ef62..fa53408 100644
--- a/netStream.go
+++ b/netStream.go
@@ -183,7 +183,9 @@ func processRtmp(conn net.Conn) {
 					amfobj := newAMFObjects()
 					if s := FindStream(streamPath); s != nil {
 						amfobj["level"] = "_result"
-						s.Close()
+						if s.Publisher != nil {
+							s.Close()
+						}
 					} else {
 						amfobj["level"] = "_error"
 					}