Function get_telethon_loop

IntelOSINT.py:314–327

()

    loop.run_forever()

def get_telethon_loop():
    global telethon_loop, _telethon_thread
    if telethon_loop is not None and _telethon_thread is not None and _telethon_thread.is_alive():
        return telethon_loop
    with _telethon_loop_lock:
        if telethon_loop is None or _telethon_thread is None or not _telethon_thread.is_alive():
            telethon_loop = asyncio.new_event_loop()
            _telethon_thread = threading.Thread(
                target=_start_background_loop,
                args=(telethon_loop,),
                daemon=True
            )
            _telethon_thread.start()
    return telethon_loop

def run_async(coro):
    loop = get_telethon_loop()