ravel.py 文件源码

def _bus_name_acquired(conn, msg, self) :
        bus_name = msg.expect_objects("s")[0]
        self.bus_names_pending.discard(bus_name)
        if bus_name not in self.bus_names_acquired :
            self.bus_names_acquired.add(bus_name)
            if self._bus_name_acquired_action != None :
                result = self._bus_name_acquired_action(self, bus_name, self._bus_name_acquired_action_arg)
                if isinstance(result, types.CoroutineType) :
                    assert self.loop != None, "no event loop to attach coroutine to"
                    self.loop.create_task(result)
                #end if
            #end if
        #end if
    #end _bus_name_acquired