diff options
-rw-r--r-- | src/io/StreamImpl.java | 9 | ||||
-rw-r--r-- | src/main/TweetShell.java | 4 | ||||
-rw-r--r-- | src/mining/Stream.java | 5 |
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. |