go/sliding-sync
go/sliding-sync
1
0
Fork 0
mirror of https://github.com/matrix-org/sliding-sync.git synced 2025-03-10 13:37:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix build

Browse Source
This commit is contained in:
David Robertson 2023-11-07 18:43:20 +00:00
parent 4011e3812a
commit 9aa8f55507
No known key found for this signature in database
GPG Key ID: 903ECE108A39DEDD
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sync3/dispatcher.go
View File

@ -55,6 +55,12 @@ func (d *Dispatcher) Startup(roomToJoinedUsers map[string][]string) error {
return nil
}
func (d *Dispatcher) Unregister(userID string) {
d.userToReceiverMu.Lock()
defer d.userToReceiverMu.Unlock()
delete(d.userToReceiver, userID)
}
// UnregisterBulk accepts a slice of user IDs to unregister. The given users need not
// already be registered (in which case unregistering them is a no-op). Returns the
// list of users that were unregistered.
@ -62,7 +68,7 @@ func (d *Dispatcher) UnregisterBulk(userIDs []string) []string {
d.userToReceiverMu.Lock()
defer d.userToReceiverMu.Unlock()
unregistered := make([]string)
unregistered := make([]string, 0)
for _, userID := range userIDs {
_, exists := d.userToReceiver[userID]
if exists {