apps/monibuca
1
0
Fork 0
mirror of https://github.com/langhuihui/monibuca.git synced 2026-05-08 12:51:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: alias auto remove

Browse Source
This commit is contained in:
langhuihui
2024-10-24 17:54:45 +08:00
parent 5795d921f5
commit a06a6cb744
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
publisher.go
+3 -3
View File
@@ -575,13 +575,13 @@ func (p *Publisher) Dispose() {
p.Paused.Reject(p.StopReason())
}
for alias := range s.AliasStreams.Range {
if alias.Alias == p.StreamPath {
if alias.StreamPath == p.StreamPath {
if alias.AutoRemove {
s.AliasStreams.Remove(alias)
}
for subscriber := range p.SubscriberRange {
if subscriber.StreamPath == alias.StreamPath {
if originStream, ok := s.Streams.Get(alias.StreamPath); ok {
if subscriber.StreamPath == alias.Alias {
if originStream, ok := s.Streams.Get(alias.Alias); ok {
p.Subscribers.Remove(subscriber)
originStream.AddSubscriber(subscriber)
}