Add some callback methods.

diff --git a/tweepy/streaming.py b/tweepy/streaming.py
index 3a5651a49a5493f73b8ab555df0f7b97eba6c0b2..de30c2cb4e756c9958da21f6c4e7e3fc5b6549b9 100644 (file)
--- a/tweepy/streaming.py
+++ b/tweepy/streaming.py
@@ -48,6 +48,14 @@ class StreamListener(object):
             delete = data['delete']['status']
             if self.on_delete(delete['id'], delete['user_id']) is False:
                 return False
+        elif 'event' in data:
+            status = Status.parse(self.api, data)
+            if self.on_event(status) is False:
+                return False
+        elif 'direct_message' in data:
+            status = Status.parse(self.api, data)
+            if self.on_direct_message(status) is False:
+                return False
         elif 'limit' in data:
             if self.on_limit(data['limit']['track']) is False:
                 return False
@@ -65,6 +73,14 @@ class StreamListener(object):
         """Called when a delete notice arrives for a status"""
         return
 
+    def on_event(self, status):
+        """Called when a new event arrives"""
+        return
+
+    def on_direct_message(self, status):
+        """Called when a new direct message arrives"""
+        return
+
     def on_limit(self, track):
         """Called when a limitation notice arrvies"""
         return