From 2bf6d00a13335efa3a3cef25245196cd866a9234 Mon Sep 17 00:00:00 2001
From: Joachim Bauch <bauch@struktur.de>
Date: Tue, 10 Mar 2026 09:06:23 +0100
Subject: [PATCH] Remove deprecated ChannelWaiter.

---
 async/channel_waiter.go      | 64 ---------------------------------
 async/channel_waiter_test.go | 69 ------------------------------------
 2 files changed, 133 deletions(-)
 delete mode 100644 async/channel_waiter.go
 delete mode 100644 async/channel_waiter_test.go

diff --git a/async/channel_waiter.go b/async/channel_waiter.go
deleted file mode 100644
index 928c7d5..0000000
--- a/async/channel_waiter.go
+++ /dev/null
@@ -1,64 +0,0 @@
-/**
- * Standalone signaling server for the Nextcloud Spreed app.
- * Copyright (C) 2023 struktur AG
- *
- * @author Joachim Bauch <bauch@struktur.de>
- *
- * @license GNU AGPL version 3 or any later version
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Affero General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU Affero General Public License for more details.
- *
- * You should have received a copy of the GNU Affero General Public License
- * along with this program.  If not, see <http://www.gnu.org/licenses/>.
- */
-package async
-
-import (
-	"sync"
-)
-
-type ChannelWaiters struct {
-	mu sync.RWMutex
-	// +checklocks:mu
-	id uint64
-	// +checklocks:mu
-	waiters map[uint64]chan struct{}
-}
-
-func (w *ChannelWaiters) Wakeup() {
-	w.mu.RLock()
-	defer w.mu.RUnlock()
-	for _, ch := range w.waiters {
-		select {
-		case ch <- struct{}{}:
-		default:
-			// Receiver is still processing previous wakeup.
-		}
-	}
-}
-
-func (w *ChannelWaiters) Add(ch chan struct{}) uint64 {
-	w.mu.Lock()
-	defer w.mu.Unlock()
-	if w.waiters == nil {
-		w.waiters = make(map[uint64]chan struct{})
-	}
-	id := w.id
-	w.id++
-	w.waiters[id] = ch
-	return id
-}
-
-func (w *ChannelWaiters) Remove(id uint64) {
-	w.mu.Lock()
-	defer w.mu.Unlock()
-	delete(w.waiters, id)
-}
diff --git a/async/channel_waiter_test.go b/async/channel_waiter_test.go
deleted file mode 100644
index 3528e64..0000000
--- a/async/channel_waiter_test.go
+++ /dev/null
@@ -1,69 +0,0 @@
-/**
- * Standalone signaling server for the Nextcloud Spreed app.
- * Copyright (C) 2023 struktur AG
- *
- * @author Joachim Bauch <bauch@struktur.de>
- *
- * @license GNU AGPL version 3 or any later version
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Affero General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU Affero General Public License for more details.
- *
- * You should have received a copy of the GNU Affero General Public License
- * along with this program.  If not, see <http://www.gnu.org/licenses/>.
- */
-package async
-
-import (
-	"testing"
-
-	"github.com/stretchr/testify/assert"
-)
-
-func TestChannelWaiters(t *testing.T) {
-	t.Parallel()
-	var waiters ChannelWaiters
-
-	ch1 := make(chan struct{}, 1)
-	id1 := waiters.Add(ch1)
-	defer waiters.Remove(id1)
-
-	ch2 := make(chan struct{}, 1)
-	id2 := waiters.Add(ch2)
-	defer waiters.Remove(id2)
-
-	waiters.Wakeup()
-	<-ch1
-	<-ch2
-
-	select {
-	case <-ch1:
-		assert.Fail(t, "should have not received another event")
-	case <-ch2:
-		assert.Fail(t, "should have not received another event")
-	default:
-	}
-
-	ch3 := make(chan struct{}, 1)
-	id3 := waiters.Add(ch3)
-	waiters.Remove(id3)
-
-	// Multiple wakeups work even without processing.
-	waiters.Wakeup()
-	waiters.Wakeup()
-	waiters.Wakeup()
-	<-ch1
-	<-ch2
-	select {
-	case <-ch3:
-		assert.Fail(t, "should have not received another event")
-	default:
-	}
-}