diff options
| author | Valery Piashchynski <[email protected]> | 2021-05-28 10:48:05 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-05-28 10:48:05 +0300 |
| commit | 5527b31b2da2b60ed8877b8c43badb73f98ec7bb (patch) | |
| tree | 3544321ff305539cc6ca735fadf972c782774f7a /plugins/websockets/executor/executor.go | |
| parent | 008f093b3de55472250470354670715115c4e4c4 (diff) | |
- Add more tests for the BST storage
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/websockets/executor/executor.go')
| -rw-r--r-- | plugins/websockets/executor/executor.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/websockets/executor/executor.go b/plugins/websockets/executor/executor.go index 8db6d9c3..97293d52 100644 --- a/plugins/websockets/executor/executor.go +++ b/plugins/websockets/executor/executor.go @@ -64,7 +64,7 @@ func (e *Executor) StartCommandLoop() error { //nolint:gocognit // handle leave case commands.Join: // associate connection with topics - e.storage.Store(e.connID, msg.Topics()) + e.storage.InsertMany(e.connID, msg.Topics()) resp := &Response{ Topic: "@join", @@ -97,7 +97,7 @@ func (e *Executor) StartCommandLoop() error { //nolint:gocognit // handle leave case commands.Leave: // remove associated connections from the storage - e.storage.Remove(e.connID, msg.Topics()) + e.storage.RemoveMany(e.connID, msg.Topics()) resp := &Response{ Topic: "@leave", |