diff options
| author | Claire <claire.github-309c@sitedethib.com> | 2022-01-07 22:43:28 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-01-07 22:43:28 +0100 |
| commit | 5b185b05f10f280bb2059920dfdb2b7f3d6f7d91 (patch) | |
| tree | d5ba55bf888811115f48d34b52485748e21ea039 /streaming | |
| parent | e2933854ac598c5ee7428a654a72cf4f4bd9afea (diff) | |
| parent | af86c7a5ded69cf8aee3ff70504c383155e40fde (diff) | |
Merge pull request #1655 from ClearlyClaire/glitch-soc/merge-upstream
Merge upstream changes
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 = [ |