Compare commits
No commits in common. "a92a9b97f05a8e3c58edb5a1747f0312a0656b7f" and "83282285cb0d6b142448d599effefda443a1d263" have entirely different histories.
a92a9b97f0
...
83282285cb
|
|
@ -412,12 +412,7 @@ func VideoFeed(c *gin.Context) {
|
||||||
// 启动一个协程来监测客户端连接是否关闭,关闭时向 clientClosed 通道发送信号
|
// 启动一个协程来监测客户端连接是否关闭,关闭时向 clientClosed 通道发送信号
|
||||||
go func() {
|
go func() {
|
||||||
<-c.Request.Context().Done()
|
<-c.Request.Context().Done()
|
||||||
//如果clientClosed通道已经关闭,不再发送
|
clientClosed <- struct{}{}
|
||||||
if _, ok := <-clientClosed; !ok {
|
|
||||||
return
|
|
||||||
} else {
|
|
||||||
clientClosed <- struct{}{}
|
|
||||||
}
|
|
||||||
}()
|
}()
|
||||||
|
|
||||||
// 查看是否还有其他连接,没有则设置 is_play 为 0
|
// 查看是否还有其他连接,没有则设置 is_play 为 0
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue