diff options
author | Peter Wu <peter@lekensteyn.nl> | 2014-05-07 12:23:23 +0200 |
---|---|---|
committer | Peter Wu <peter@lekensteyn.nl> | 2014-05-07 12:23:23 +0200 |
commit | 489df8f0dd22043507299d02f934fe0213ca29e6 (patch) | |
tree | f09a5ae573c8c086abec8b942548533d812aa68c /src/provider | |
parent | 6955aaa7c469878dc75fb80a036034eaef723e7d (diff) | |
download | TwitterDataAnalytics-489df8f0dd22043507299d02f934fe0213ca29e6.tar.gz |
Add flush command
Diffstat (limited to 'src/provider')
-rw-r--r-- | src/provider/CompositeResultListener.java | 20 |
1 files changed, 19 insertions, 1 deletions
diff --git a/src/provider/CompositeResultListener.java b/src/provider/CompositeResultListener.java index dc4a754..64a8a0b 100644 --- a/src/provider/CompositeResultListener.java +++ b/src/provider/CompositeResultListener.java @@ -1,8 +1,12 @@ package provider; import java.io.Closeable; +import java.io.Flushable; +import java.io.IOException; import java.util.ArrayList; import java.util.List; +import java.util.logging.Level; +import java.util.logging.Logger; import org.apache.commons.io.IOUtils; import org.json.JSONObject; @@ -11,7 +15,8 @@ import org.json.JSONObject; * * @author Peter Wu */ -public class CompositeResultListener implements ResultListener, Closeable { +public class CompositeResultListener implements ResultListener, Closeable, + Flushable { private final List<ResultListener> listeners; @@ -55,4 +60,17 @@ public class CompositeResultListener implements ResultListener, Closeable { } } } + + public void flush() { + for (ResultListener rl : listeners) { + if (rl instanceof Flushable) { + try { + ((Flushable) rl).flush(); + } catch (IOException ex) { + Logger.getLogger(rl.getClass().getName()) + .log(Level.SEVERE, "flush", ex); + } + } + } + } } |