From b9b2e9458ddfd6108685e198104d8c82b3ddc247 Mon Sep 17 00:00:00 2001
From: Peter Wu <peter@lekensteyn.nl>
Date: Wed, 7 May 2014 10:34:43 +0200
Subject: StreamImpl: make (un)watchKeywords support a list

---
 src/io/StreamImpl.java | 24 ++++++++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

(limited to 'src/io/StreamImpl.java')

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
-- 
cgit v1.2.1