from time import sleep
-import unittest
+import unittest2 as unittest
from tweepy.api import API
+ from tweepy.auth import OAuthHandler
from tweepy.models import Status
from tweepy.streaming import Stream, StreamListener
else:
error_counter = 0
self.retry_time = self.retry_time_start
- self.snooze_time = self.snooze_time_start
+ self.snooze_time = self.snooze_time_step
self.listener.on_connect()
self._read_loop(resp)
- except timeout:
+ except (timeout, ssl.SSLError), exc:
+ # If it's not time out treat it like any other exception
+ if isinstance(exc, ssl.SSLError) and not (exc.args and 'timed out' in str(exc.args[0])):
+ exception = exc
+ break
+
if self.listener.on_timeout() == False:
break
if self.running is False: