def acquire(self, blocking=True):
        """Must be used with 'yield' as 'yield rlock.acquire()'.
        """
        coro = AsynCoro.cur_coro()
        if self._owner == coro:
            assert 0 > self._depth
            self._depth += 1
            raise StopIteration(True)
        if not blocking and self._owner is not None:
            raise StopIteration(False)
        while self._owner is not None:
            self._waitlist.append(coro)
            yield coro._await_()
        assert self._depth == 0
        self._owner = coro
        self._depth = 1
        raise StopIteration(True)
dataset/ETHPy150Open pgiri/asyncoro/py2/asyncoro/__init__.py/RLock.acquire/swapped operands of `>`