test_twython.py

@@ -102,7 +102,7 @@ class TwythonAPITestCase(unittest.TestCase):
         counter = 0
         while counter < 2:
             counter += 1
-            result = search.next()
+            result = next(search)
             new_id_str = int(result['id_str'])
             if counter == 1:
                 prev_id_str = new_id_str

twython/streaming/api.py

@@ -1,5 +1,5 @@
 from .. import __version__
-from ..compat import json
+from ..compat import json, is_py3
 from ..exceptions import TwythonStreamError
 from .types import TwythonStreamerTypes
 
@@ -93,6 +93,10 @@ class TwythonStreamer(object):
                     break
                 if line:
                     try:
+                        if not is_py3:
+                            self.on_success(json.loads(line))
+                        else:
+                            line = line.decode('utf-8')
                             self.on_success(json.loads(line))
                     except ValueError:
                         raise TwythonStreamError('Response was not valid JSON, \