original_docstring: Called when raw data is received from connection.
  
          Override this method if you wish to manually handle
          the stream data.
          
docstring: Called when raw data is received from connection.
  Override this method if you wish to manually handle
  the stream data.
docstring_tokens: Called when raw data is received from connection . Override this method if you wish to manually handle the stream data .
code: def on_data(self, raw_data):
          """Called when raw data is received from connection.
  
          Override this method if you wish to manually handle
          the stream data.
          """
          data = json.loads(raw_data)
  
          if 'in_reply_to_status_id' in data:
              status = Status.parse(None, data)
              return self.on_status(status)
          if 'delete' in data:
              delete = data['delete']['status']
              return self.on_delete(delete['id'], delete['user_id'])
          if 'disconnect' in data:
              return self.on_disconnect_message(data['disconnect'])
          if 'limit' in data:
              return self.on_limit(data['limit']['track'])
          if 'scrub_geo' in data:
              return self.on_scrub_geo(data['scrub_geo'])
          if 'status_withheld' in data:
              return self.on_status_withheld(data['status_withheld'])
          if 'user_withheld' in data:
              return self.on_user_withheld(data['user_withheld'])
          if 'warning' in data:
              return self.on_warning(data['warning'])
  
          log.error("Unknown message type: %s", raw_data)
code_tokens: def on_data ( self , raw_data ) : data = json . loads ( raw_data ) if 'in_reply_to_status_id' in data : status = Status . parse ( None , data ) return self . on_status ( status ) if 'delete' in data : delete = data [ 'delete' ] [ 'status' ] return self . on_delete ( delete [ 'id' ] , delete [ 'user_id' ] ) if 'disconnect' in data : return self . on_disconnect_message ( data [ 'disconnect' ] ) if 'limit' in data : return self . on_limit ( data [ 'limit' ] [ 'track' ] ) if 'scrub_geo' in data : return self . on_scrub_geo ( data [ 'scrub_geo' ] ) if 'status_withheld' in data : return self . on_status_withheld ( data [ 'status_withheld' ] ) if 'user_withheld' in data : return self . on_user_withheld ( data [ 'user_withheld' ] ) if 'warning' in data : return self . on_warning ( data [ 'warning' ] ) log . error ( "Unknown message type: %s" , raw_data )
short_docstring: Called when raw data is received from connection.
short_docstring_tokens: Called when raw data is received from connection .
comment: """Called when raw data is received from connection.
  
          Override this method if you wish to manually handle
          the stream data.
          """