Use abstract StreamingHandler

Author: tmoskovitch

examples/src/main/java/com/twitter/clientlib/HelloWorldStreaming.java

@@ -44,7 +44,7 @@ public static void main(String[] args) {
           .executeListeners();
       while(tsle.getError() == null) {
         try {
-          System.err.println("==> sleeping 5 ");
+          System.out.println("==> sleeping 5 ");
           Thread.sleep(5000);
         } catch (InterruptedException e) {
           e.printStackTrace();

examples/src/main/java/com/twitter/clientlib/StreamingHandler.java

@@ -22,16 +22,22 @@
 
 package com.twitter.clientlib;
 
+import java.io.InputStream;
+
 import com.twitter.clientlib.api.TwitterApi;
 
-public abstract class StreamingHandler<T> implements IStreamingHandler<T> {
+public abstract class StreamingHandler<T> {
 protected final TwitterApi apiInstance;
 
   public StreamingHandler(TwitterApi apiInstance) {
     this.apiInstance = apiInstance;
   }
 
-  @Override
+  public abstract InputStream connectStream() throws ApiException;
+  public abstract void actionOnStreamingObject(T streamingTweet) throws ApiException;
+  public abstract T getStreamingObject(String tweetString) throws Exception;
+  public abstract boolean hasReconnectErrors(T streamingTweet);
+
   public boolean processAndVerifyStreamingObject(String tweetString) throws Exception {
     T tweet = getStreamingObject(tweetString);
     actionOnStreamingObject(tweet);

examples/src/main/java/com/twitter/clientlib/TweetsStreamListenersExecutor.java

@@ -41,7 +41,7 @@ public class TweetsStreamListenersExecutor {
   private final AtomicBoolean isRunning = new AtomicBoolean(true);
   private final AtomicLong tweetStreamedTime = new AtomicLong(0);
   private Exception caughtException;
-  private IStreamingHandler<?> streamingHandler;
+  private StreamingHandler<?> streamingHandler;
   private long reconnecting = 0;
 
   public StreamListenersExecutorBuilder stream() {
@@ -173,7 +173,7 @@ public void checkTimes()  {
   }
 
   public class StreamListenersExecutorBuilder {
-    public StreamListenersExecutorBuilder streamingHandler(IStreamingHandler<?> streamHandler) {
+    public StreamListenersExecutorBuilder streamingHandler(StreamingHandler<?> streamHandler) {
       streamingHandler = streamHandler;
       return this;
     }