Commit 827b767e authored by joausaga's avatar joausaga
Browse files

Extend on_data method by including a conditional to process warning messages...

Extend on_data method by including a conditional to process warning messages and add the definition of the method to manage those warning messages
parent 3a44f136
......@@ -68,6 +68,9 @@ class StreamListener(object):
elif 'disconnect' in data:
if self.on_disconnect(data['disconnect']) is False:
return False
elif 'warning' in data:
if self.on_warning(data['warning']) is False:
return False
else:
logging.error("Unknown message type: " + str(raw_data))
......@@ -99,7 +102,7 @@ class StreamListener(object):
return
def on_limit(self, track):
"""Called when a limitation notice arrvies"""
"""Called when a limitation notice arrives"""
return
def on_error(self, status_code):
......@@ -117,6 +120,10 @@ class StreamListener(object):
https://dev.twitter.com/docs/streaming-apis/messages#Disconnect_messages_disconnect
"""
return
def on_warning(self, notice):
"""Called when a disconnection warning message arrives"""
return
class ReadBuffer(object):
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment