code: def consume(self, data):
          
          if not self._started:
              self.fire(JSONStreamer.DOC_START_EVENT)
              self._started = True
          self._file_like.write(data)
          try:
              self._parser.parse(self._file_like)
          except YajlError as ye:
              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