def _ordered_iter(self):
try:<EOL><INDENT>rlist = self.get(<NUM_LIT:0>)<EOL><DEDENT>except error.TimeoutError:<EOL><INDENT>for msg_id in self.msg_ids:<EOL><INDENT>ar = AsyncResult(self._client, msg_id, self._fname)<EOL>rlist = ar.get()<EOL>try:<EOL><INDENT>for r in rlist:<EOL><INDENT>yield r<EOL><DEDENT><DEDENT>except TypeError:<EOL><INDENT>yield rlist<EOL><DEDENT><DEDENT><DEDENT>else:<EOL><INDENT>for r in rlist:<EOL><INDENT>yield r<EOL><DEDENT><DEDENT>
iterator for results *as they arrive*, preserving submission order.