diff options
author | Peter Wu <peter@lekensteyn.nl> | 2014-05-01 18:13:22 +0200 |
---|---|---|
committer | Peter Wu <peter@lekensteyn.nl> | 2014-05-01 18:13:22 +0200 |
commit | 9c8e5991bea5e5b188b7623d8ba749db4b4b1182 (patch) | |
tree | 8ae24a88c4c39c6afe11fb397b2b022aa5b179e9 | |
parent | 6f31522cdb498be2e7b42f59c16538d98f83471a (diff) | |
download | TwitterDataAnalytics-9c8e5991bea5e5b188b7623d8ba749db4b4b1182.tar.gz |
Do not destroy the old file...
-rw-r--r-- | src/main/TweetShell.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/main/TweetShell.java b/src/main/TweetShell.java index 0849592..475590d 100644 --- a/src/main/TweetShell.java +++ b/src/main/TweetShell.java @@ -216,12 +216,7 @@ public class TweetShell implements TwitterApi.PinSupplier { throw new NoSuchElementException(); case target: StreamImpl stream = (StreamImpl) getStream(); - ResultListener oldListener = stream.getResultListener(); - if (oldListener instanceof DataWriter) { - ((DataWriter) oldListener).close(); - } - switch (params[0]) { case "file": if (!(oldListener instanceof DataWriter)) { @@ -237,10 +232,16 @@ public class TweetShell implements TwitterApi.PinSupplier { } break; case "shell": + if (oldListener instanceof DataWriter) { + ((DataWriter) oldListener).close(); + } if (!(oldListener instanceof StreamHandler)) { stream.setResultListener(new StreamHandler()); } break; + default: + System.err.println("Unrecognized target " + params[0]); + break; } break; default: @@ -248,5 +249,4 @@ public class TweetShell implements TwitterApi.PinSupplier { } } -; } |