diff --git a/streaming/index.js b/streaming/index.js
index 3565ed2783..e599b19042 100644
--- a/streaming/index.js
+++ b/streaming/index.js
@@ -789,7 +789,7 @@ const startServer = async () => {
       // filtering of statuses:
 
       // Filter based on language:
-      if (Array.isArray(req.chosenLanguages) && payload.language !== null && req.chosenLanguages.indexOf(payload.language) === -1) {
+      if (Array.isArray(req.chosenLanguages) && req.chosenLanguages.indexOf(payload.language) === -1) {
         log.silly(req.requestId, `Message ${payload.id} filtered by language (${payload.language})`);
         return;
       }