1 files changed, 2 insertions, 2 deletions
diff --git a/src/io/StreamImpl.java b/src/io/StreamImpl.java
index b6be055..6d6ba64 100644
--- a/src/io/StreamImpl.java
+++ b/src/io/StreamImpl.java
@@ -11,7 +11,6 @@ import java.util.HashSet;
 import java.util.Set;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.logging.Logger;
-import java.util.zip.GZIPInputStream;
 import mining.Stream;
 import org.apache.commons.io.Charsets;
 import org.apache.commons.lang.StringUtils;
@@ -20,6 +19,7 @@ import org.json.JSONObject;
 import org.json.JSONTokener;
 import provider.ExceptionListener;
 import provider.ResultListener;
+import support.StreamingGZIPInputStream;
 
 /**
  * Provides access to Twitter stream data. Data is processed in a separate
@@ -188,7 +188,7 @@ public class StreamImpl implements Stream {
          */
         private InputStream wrapGzip(InputStream is) throws IOException {
             if ("gzip".equals(connection.getContentEncoding())) {
-                return new GZIPInputStream(is);
+                return new StreamingGZIPInputStream(is);
             }
             return is;
         }