luciano/htmgo
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove listener

Browse source
This commit is contained in:
maddalax 2024-11-12 13:09:33 -06:00
parent 423fd3f429
commit 3fda1039a9
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
extensions/websocket/ws/manager.go
View file

@ -185,6 +185,17 @@ func (manager *SocketManager) Listen(listener chan SocketEvent) {
}
}
func (manager *SocketManager) RemoveListener(listener chan SocketEvent) {
for i, l := range manager.listeners {
if l == listener {
slog.Debug("ws-extension: removed listener from manager")
manager.listeners = append(manager.listeners[:i], manager.listeners[i+1:]...)
slog.Debug("ws-extension: total listeners", slog.Int("count", len(manager.listeners)))
return
}
}
}
func (manager *SocketManager) dispatch(event SocketEvent) {
done := make(chan struct{}, 1)
go func() {