code: def _stream_search(self, *args, **kwargs):
          
          for hit in scan(
              self.elastic, query=kwargs.pop("body", None), scroll="10m", **kwargs
          ):
              hit["_source"]["_id"] = hit["_id"]
              yield hit["_source"]
docs: Helper method for iterating over ES search results.