diff options
| author | Claire <claire.github-309c@sitedethib.com> | 2022-01-07 19:51:47 +0100 |
|---|---|---|
| committer | Claire <claire.github-309c@sitedethib.com> | 2022-01-07 19:51:47 +0100 |
| commit | fca50e4b50d8b2007fa733c7b732aeab6b2092d7 (patch) | |
| tree | 446de962f769185e739b9e4b09e2530e2e311437 /streaming | |
| parent | e2933854ac598c5ee7428a654a72cf4f4bd9afea (diff) | |
| parent | bc066d8936e2cfaa2dc275d9a5d4aefc0cbc1d86 (diff) | |
Merge branch 'main' into glitch-soc/merge-upstream
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/index.js | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/streaming/index.js b/streaming/index.js index ff873cd04..2dbb546c0 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -197,10 +197,12 @@ const startWorker = async (workerId) => { /** * @param {string} channel + * @param {function(string): void} callback */ - const unsubscribe = (channel) => { + const unsubscribe = (channel, callback) => { + log.silly(`Removing listener for ${channel}`); - redisSubscribeClient.unsubscribe(channel); + redisSubscribeClient.unsubscribe(channel, callback); }; const FALSE_VALUES = [ |