mirror of
https://github.com/eternnoir/pyTelegramBotAPI.git
synced 2023-08-10 21:12:57 +03:00
Fix unnecessary Thread creation when no new messages arrived.
This commit is contained in:
parent
0068388872
commit
949dfc0fb0
@ -44,13 +44,15 @@ class TeleBot:
|
|||||||
def get_update(self):
|
def get_update(self):
|
||||||
result = apihelper.get_updates(self.token, offset=(self.last_update_id + 1))
|
result = apihelper.get_updates(self.token, offset=(self.last_update_id + 1))
|
||||||
updates = result['result']
|
updates = result['result']
|
||||||
notify_updates = []
|
new_messages = []
|
||||||
for update in updates:
|
for update in updates:
|
||||||
if update['update_id'] > self.last_update_id:
|
if update['update_id'] > self.last_update_id:
|
||||||
self.last_update_id = update['update_id']
|
self.last_update_id = update['update_id']
|
||||||
msg = types.Message.de_json(json.dumps(update['message']))
|
msg = types.Message.de_json(json.dumps(update['message']))
|
||||||
notify_updates.append(msg)
|
new_messages.append(msg)
|
||||||
self.__notify_update(notify_updates)
|
|
||||||
|
if len(new_messages) > 0:
|
||||||
|
self.__notify_update(new_messages)
|
||||||
|
|
||||||
def __notify_update(self, new_messages):
|
def __notify_update(self, new_messages):
|
||||||
for listener in self.update_listener:
|
for listener in self.update_listener:
|
||||||
|
Loading…
Reference in New Issue
Block a user