Add streaming test_sample test.

joshthecoder · joshthecoder · commit a592b1b3b54c · 2013-05-18T23:59:12.000-07:00
diff --git a/tests/test_streaming.py b/tests/test_streaming.py
@@ -2,36 +2,52 @@
 import unittest
 
 from tweepy.api import API
+from tweepy.models import Status
 from tweepy.streaming import Stream, StreamListener
 
 from config import create_auth
 from mock import mock_tweet
 
 class MockStreamListener(StreamListener):
-    def __init__(self):
+    def __init__(self, test_case):
         super(MockStreamListener, self).__init__()
+        self.test_case = test_case
         self.status_count = 0
+        self.status_stop_count = 0
+        self.connect_cb = None
+
+    def on_connect(self):
+        if self.connect_cb:
+            self.connect_cb()
 
     def on_status(self, status):
         self.status_count += 1
-        return False
+        self.test_case.assertIsInstance(status, Status)
+        if self.status_stop_count == self.status_count:
+            return False
 
 class TweepyStreamTests(unittest.TestCase):
     def setUp(self):
         self.auth = create_auth()
-        self.listener = MockStreamListener()
+        self.listener = MockStreamListener(self)
         self.stream = Stream(self.auth, self.listener)
 
     def tearDown(self):
         self.stream.disconnect()
 
     def test_userstream(self):
-        self.stream.userstream(async=True)
-
         # Generate random tweet which should show up in the stream.
-        # Wait a bit of time for it to arrive before asserting.
-        API(self.auth).update_status(mock_tweet())
-        sleep(1)
+        def on_connect():
+            API(self.auth).update_status(mock_tweet())
 
+        self.listener.connect_cb = on_connect
+        self.listener.status_stop_count = 1
+        self.stream.userstream()
         self.assertEqual(self.listener.status_count, 1)
 
+    def test_sample(self):
+        self.listener.status_stop_count = 10
+        self.stream.sample()
+        self.assertEquals(self.listener.status_count,
+                          self.listener.status_stop_count)
+
