(self)
Blocks until the event is set.
Blocks until the event is set.
Blocks until the event is set .
def wait(self) -> None:
        """Blocks until the event is set."""
        with self.lock:
            is_set = self.is_set
        if is_set:
            return
        p = redis_connection.pubsub(ignore_subscribe_messages=True)
        p.subscribe(self.name)
        next(p.listen())
        p.close()
def wait ( self ) -> None : with self . lock : is_set = self . is_set if is_set : return p = redis_connection . pubsub ( ignore_subscribe_messages = True ) p . subscribe ( self . name ) next ( p . listen ( ) ) p . close ( )