diff --git a/src/tweets/collector.py b/src/tweets/collector.py
index 97b2c34..80be71e 100644
--- a/src/tweets/collector.py
+++ b/src/tweets/collector.py
@@ -70,13 +70,9 @@ class Streamer():
                 stream.filter(languages=["en"], track=hashtag)
             except IncompleteRead:
                 log("Incomplete Read Error", 'ERR')
-                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
-                stream.filter(languages=["en"], track=hashtag)
                 continue
             except ProtocolError:
                 log("Protocol Error", 'ERR')
-                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
-                stream.filter(languages=["en"], track=hashtag)
                 continue
 
 class Listener(StreamListener):