@wrap_exceptions<EOL><INDENT>def _stream_search(self, *args, **kwargs):<DEDENT>
for hit in scan(self.elastic, query=kwargs.pop('<STR_LIT:body>', None),<EOL>scroll='<STR_LIT>', **kwargs):<EOL><INDENT>hit['<STR_LIT>']['<STR_LIT>'] = hit['<STR_LIT>']<EOL>yield hit['<STR_LIT>']<EOL><DEDENT>
Helper method for iterating over ES search results.