From 9aa8f55507da26e5ad93fd07bf874595a62d8cc2 Mon Sep 17 00:00:00 2001 From: David Robertson Date: Tue, 7 Nov 2023 18:43:20 +0000 Subject: [PATCH] Fix build --- sync3/dispatcher.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/sync3/dispatcher.go b/sync3/dispatcher.go index 9385d1b..a7bb24b 100644 --- a/sync3/dispatcher.go +++ b/sync3/dispatcher.go @@ -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 {