Method wait

raiden/waiting.py:230–242

(self, condition: ChannelStateCondition)

        )

    def wait(self, condition: ChannelStateCondition) -> None:
        chain_state = views.state_from_raiden(self.raiden)
        while not condition(chain_state, self._get_channel_state(chain_state)):
            assert self.raiden.is_running(), ALARM_TASK_ERROR_MSG
            assert self.raiden.alarm.is_running(), ALARM_TASK_ERROR_MSG
            log.debug(
                "Waiting on channel",
                node=to_checksum_address(self.raiden.address),
                partner_address=to_checksum_address(self.partner_address),
                condition=condition,
            )
            gevent.sleep(self.retry_timeout)
            chain_state = views.state_from_raiden(self.raiden)


def _get_canonical_identifier_by_channel_id(