Added retweet streaming method.

diff --git a/CHANGES b/CHANGES
index 6a79644dc46c07a4463c2330d0a3dab3360de59a..357a440c6b2cdd967c0980d7edb650bb165a29e3 100644 (file)
--- a/CHANGES
+++ b/CHANGES
@@ -6,6 +6,7 @@ during upgrade will be listed here.
 + Fixes
     + Google App Engine fixes (thanks Thomas Bohmbach, Jr)
 + Added Retweet API methods
++ Added Retweet Streaming method
 
 1.0 -> 1.0.1
 ============

diff --git a/ROADMAP b/ROADMAP
index b76fe1c8df35eb134d226d6c198395e93633a0b6..40464e296b39fd47e614627767fdc284425c6bbf 100644 (file)
--- a/ROADMAP
+++ b/ROADMAP
@@ -4,5 +4,5 @@ The plan of attack for the next version of Tweepy.
 ============
 + implement win32 file locking for FileCache
 + add retweet API methods [DONE]
-+ add retweet streaming method
++ add retweet streaming method [DONE]
 

diff --git a/tweepy/streaming.py b/tweepy/streaming.py
index 947d633e27a973dae483b7f311dbfce1340e2d84..738d05ed513ec30521eeaec02f44772a9b44521f 100644 (file)
--- a/tweepy/streaming.py
+++ b/tweepy/streaming.py
@@ -151,6 +151,13 @@ class Stream(object):
         self.running = True
         Thread(target=self._run).start()
 
+    def retweet(self):
+        if self.running:
+            raise TweepError('Stream object already connected!')
+        self.url = '/%i/statuses/retweet.json?delimited=length' % STREAM_VERSION
+        self.running = True
+        Thread(target=self._run).start()
+
     def sample(self, count=None):
         if self.running:
             raise TweepError('Stream object already connected!')