mirror of
https://github.com/pyrogram/pyrogram
synced 2025-09-02 07:15:23 +00:00
@@ -33,6 +33,11 @@ class ContinuePropagation(StopAsyncIteration):
|
|||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
import asyncio
|
||||||
|
|
||||||
from . import raw, types, filters, handlers, emoji
|
from . import raw, types, filters, handlers, emoji
|
||||||
from .client import Client
|
from .client import Client
|
||||||
from .sync import idle
|
from .sync import idle
|
||||||
|
|
||||||
|
# Save the main thread loop for future references
|
||||||
|
main_event_loop = asyncio.get_event_loop()
|
||||||
|
@@ -23,6 +23,7 @@ import re
|
|||||||
import sys
|
import sys
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
|
|
||||||
|
import pyrogram
|
||||||
from pyrogram import __version__
|
from pyrogram import __version__
|
||||||
from pyrogram.parser import Parser
|
from pyrogram.parser import Parser
|
||||||
from pyrogram.session.internals import MsgId
|
from pyrogram.session.internals import MsgId
|
||||||
@@ -73,6 +74,13 @@ class Scaffold:
|
|||||||
mime_types_to_extensions[mime_type] = " ".join(extensions)
|
mime_types_to_extensions[mime_type] = " ".join(extensions)
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
|
try:
|
||||||
|
asyncio.get_event_loop()
|
||||||
|
except RuntimeError:
|
||||||
|
# This happens when creating Client instances inside different threads that don't have an event loop.
|
||||||
|
# Set the main event loop in this thread.
|
||||||
|
asyncio.set_event_loop(pyrogram.main_event_loop)
|
||||||
|
|
||||||
self.session_name = None
|
self.session_name = None
|
||||||
self.api_id = None
|
self.api_id = None
|
||||||
self.api_hash = None
|
self.api_hash = None
|
||||||
|
Reference in New Issue
Block a user