summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPeter Wu <peter@lekensteyn.nl>2014-05-01 18:50:18 +0200
committerPeter Wu <peter@lekensteyn.nl>2014-05-01 18:50:18 +0200
commit70bde08fb9201e85c16ff1bc6130fc0453b4d54e (patch)
treef0ce8372a5d507012919cf33574ef285f888100b
parent9c8e5991bea5e5b188b7623d8ba749db4b4b1182 (diff)
downloadTwitterDataAnalytics-70bde08fb9201e85c16ff1bc6130fc0453b4d54e.tar.gz
Get rid of unused and broken poll function
-rw-r--r--src/io/StreamImpl.java9
-rw-r--r--src/main/TweetShell.java4
-rw-r--r--src/mining/Stream.java5
3 files changed, 0 insertions, 18 deletions
diff --git a/src/io/StreamImpl.java b/src/io/StreamImpl.java
index 4141711..cba9fdd 100644
--- a/src/io/StreamImpl.java
+++ b/src/io/StreamImpl.java
@@ -111,15 +111,6 @@ public class StreamImpl implements Stream {
}
@Override
- public void poll() {
- // HACK: change this, strengten contract
- try {
- workerContainer.thread.join();
- } catch (InterruptedException ex) {
- }
- }
-
- @Override
public void close() {
disconnect();
}
diff --git a/src/main/TweetShell.java b/src/main/TweetShell.java
index 475590d..c1391ac 100644
--- a/src/main/TweetShell.java
+++ b/src/main/TweetShell.java
@@ -131,7 +131,6 @@ public class TweetShell implements TwitterApi.PinSupplier {
del("Deletes a keyword from search", 1),
commit("Activate the stream or apply the stream keyword changes"),
close("Close the stream"),
- test(""),
exit("Returns to shell"),
help("Get help"),
target("Set output target: {file, shell}.");
@@ -192,9 +191,6 @@ public class TweetShell implements TwitterApi.PinSupplier {
case close:
getStream().close();
break;
- case test:
- getStream().poll();
- break;
case help:
for (String line : HELP) {
System.out.println(line);
diff --git a/src/mining/Stream.java b/src/mining/Stream.java
index 083a6c8..36fba1b 100644
--- a/src/mining/Stream.java
+++ b/src/mining/Stream.java
@@ -39,11 +39,6 @@ public interface Stream {
public void close();
/**
- * Blocking call until a new event is available.
- */
- public void poll();
-
- /**
* Test whether the stream is ready for streaming
*
* @return true if connection can be made, false otherwise.