|
10 | 10 | rpc_message_to_error |
11 | 11 | ) |
12 | 12 | from ..extensions import BinaryReader |
13 | | -from ..tl import Message, MessageContainer, GzipPacked |
| 13 | +from ..tl import TLMessage, MessageContainer, GzipPacked |
14 | 14 | from ..tl.all_tlobjects import tlobjects |
15 | 15 | from ..tl.types import MsgsAck |
16 | 16 |
|
@@ -69,21 +69,21 @@ def send(self, *requests): |
69 | 69 | self._send_acknowledges() |
70 | 70 |
|
71 | 71 | # Finally send our packed request(s) |
72 | | - messages = [Message(self.session, r) for r in requests] |
| 72 | + messages = [TLMessage(self.session, r) for r in requests] |
73 | 73 | self._pending_receive.update({m.msg_id: m for m in messages}) |
74 | 74 |
|
75 | 75 | if len(messages) == 1: |
76 | 76 | message = messages[0] |
77 | 77 | else: |
78 | | - message = Message(self.session, MessageContainer(messages)) |
| 78 | + message = TLMessage(self.session, MessageContainer(messages)) |
79 | 79 |
|
80 | 80 | self._send_message(message) |
81 | 81 |
|
82 | 82 | def _send_acknowledges(self): |
83 | 83 | """Sends a messages acknowledge for all those who _need_confirmation""" |
84 | 84 | if self._need_confirmation: |
85 | 85 | self._send_message( |
86 | | - Message(self.session, MsgsAck(self._need_confirmation)) |
| 86 | + TLMessage(self.session, MsgsAck(self._need_confirmation)) |
87 | 87 | ) |
88 | 88 | del self._need_confirmation[:] |
89 | 89 |
|
|
0 commit comments