diff options
author | Peter Wu <peter@lekensteyn.nl> | 2014-05-07 10:34:43 +0200 |
---|---|---|
committer | Peter Wu <peter@lekensteyn.nl> | 2014-05-07 10:34:43 +0200 |
commit | b9b2e9458ddfd6108685e198104d8c82b3ddc247 (patch) | |
tree | 10786ccb767c0d401ef85d9879c8ea3fa015a65f /src | |
parent | 0fbe4a076ea1aa342fd4bdc23e10107c3e9aaa0c (diff) | |
download | TwitterDataAnalytics-b9b2e9458ddfd6108685e198104d8c82b3ddc247.tar.gz |
StreamImpl: make (un)watchKeywords support a list
Diffstat (limited to 'src')
-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 |