@wrap_exceptions<EOL><INDENT>def _stream_search(self, *args, **kwargs):<DEDENT>
for hit in scan(<EOL>self.elastic, query=kwargs.pop("<STR_LIT:body>", None), scroll="<STR_LIT>", **kwargs<EOL>):<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.