diff options
| -rw-r--r-- | src/io/StreamImpl.java | 24 |
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 |