Add flush command

1 files changed, 7 insertions, 0 deletions

diff --git a/src/main/TweetShell.java b/src/main/TweetShell.java
index 8b801ea..e8d387d 100644
--- a/src/main/TweetShell.java
+++ b/src/main/TweetShell.java
@@ -5,6 +5,7 @@ import io.DataWriter;
 import io.OAuthRequester;
 import io.StreamImpl;
 import java.io.Closeable;
+import java.io.Flushable;
 import java.io.IOException;
 import java.text.DateFormat;
 import java.text.SimpleDateFormat;
@@ -195,6 +196,7 @@ public class TweetShell implements TwitterApi.PinSupplier {
         keywords("Display currently active keywords"),
         commit("Activate the stream or apply the stream keyword changes"),
         status("Show some status and statistics"),
+        flush("Writes any pending buffers"),
         close("Close the stream"),
         exit("Returns to shell"),
         help("Get help"),
@@ -306,6 +308,11 @@ public class TweetShell implements TwitterApi.PinSupplier {
                 System.out.println("Received tweets in session: " + tc.getTweetCount());
                 System.out.println("Unique users: " + tc.getUsers().size());
                 break;
+            case flush:
+                if (stream_cached != null) {
+                    resultListeners.flush();
+                }
+                break;
             case close:
                 safeClose();
                 break;