fix goroutine leak

protocol/rtmp/rtmprelay/rtmprelay.go

@@ -77,7 +77,7 @@ func (self *RtmpRelay) sendPublishChunkStream() {
 			if ctrlcmd == STOP_CTRL {
 				self.connectPublishClient.Close(nil)
 				log.Debugf("sendPublishChunkStream close: playurl=%s, publishurl=%s", self.PlayUrl, self.PublishUrl)
-				break
+				return
 			}
 		}
 	}

protocol/rtmp/rtmprelay/staticrelay.go

@@ -170,7 +170,7 @@ func (self *StaticPush) HandleAvPacket() {
 			if ctrlcmd == STATIC_RELAY_STOP_CTRL {
 				self.connectClient.Close(nil)
 				log.Debugf("Static HandleAvPacket close: publishurl=%s", self.RtmpUrl)
-				break
+				return
 			}
 		}
 	}