token_swap.py 文件源码

def _messages_until_block(self, raiden, expiration_block):
        """ Returns the received messages up to the block `expiration_block`.
        """
        current_block = raiden.get_block_number()
        while current_block < expiration_block:
            try:
                response = self.response_queue.get(
                    timeout=DEFAULT_EVENTS_POLL_TIMEOUT,
                )
            except Empty:
                pass
            else:
                if response:
                    yield response

            current_block = raiden.get_block_number()