code: def consume(self, data):
          
          try:
              self._streamer.consume(data)
          except YajlError as ye:
              print(ye.value)
              raise JSONStreamerException(ye.value)
docs: Takes input that must be parsed
  
          Note:
              Attach all your listeners before calling this method
  
          Args:
              data (str): input json string