StreamImpl: make (un)watchKeywords support a list

1 files changed, 20 insertions, 4 deletions

diff --git a/src/io/StreamImpl.java b/src/io/StreamImpl.java
index 4b3dd14..84d9d83 100644
--- a/src/io/StreamImpl.java
+++ b/src/io/StreamImpl.java
@@ -9,6 +9,7 @@ import java.net.URL;
 import java.net.URLEncoder;
 import java.util.Arrays;
 import java.util.HashSet;
+import java.util.List;
 import java.util.Set;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
@@ -87,14 +88,29 @@ public class StreamImpl implements Stream {
         }
     }
 
+    private Set<String> splitKeywords(String rawKeywords) {
+        Set<String> filteredKeywords = new HashSet<>();
+        List<String> keywordsList = Arrays.asList(rawKeywords.split(","));
+        for (String keyword : keywordsList) {
+            if (!keyword.isEmpty()) {
+                filteredKeywords.add(keyword);
+            }
+        }
+        return filteredKeywords;
+    }
+
     @Override
-    public void watchKeyword(String keyword) {
-        keywords.add(keyword);
+    public void watchKeyword(String rawKeywords) {
+        for (String keyword : splitKeywords(rawKeywords)) {
+            keywords.add(keyword);
+        }
     }
 
     @Override
-    public void unwatchKeyword(String keyword) {
-        keywords.remove(keyword);
+    public void unwatchKeyword(String rawKeywords) {
+        for (String keyword : splitKeywords(rawKeywords)) {
+            keywords.remove(keyword);
+        }
     }
 
     @Override