mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2025-08-05 20:50:22 +03:00
Remove missing async/await
This commit is contained in:
parent
71d2907017
commit
1f7e8ad279
|
@ -18,13 +18,13 @@ class StopPropagation(Exception):
|
||||||
>>> client = TelegramClient(...)
|
>>> client = TelegramClient(...)
|
||||||
>>>
|
>>>
|
||||||
>>> @client.on(events.NewMessage)
|
>>> @client.on(events.NewMessage)
|
||||||
... async def delete(event):
|
... def delete(event):
|
||||||
... await event.delete()
|
... event.delete()
|
||||||
... # No other event handler will have a chance to handle this event
|
... # No other event handler will have a chance to handle this event
|
||||||
... raise StopPropagation
|
... raise StopPropagation
|
||||||
...
|
...
|
||||||
>>> @client.on(events.NewMessage)
|
>>> @client.on(events.NewMessage)
|
||||||
... async def _(event):
|
... def _(event):
|
||||||
... # Will never be reached, because it is the second handler
|
... # Will never be reached, because it is the second handler
|
||||||
... pass
|
... pass
|
||||||
"""
|
"""
|
||||||
|
|
|
@ -16,10 +16,10 @@ class ConnectionHttp(Connection):
|
||||||
self.write = self.conn.write
|
self.write = self.conn.write
|
||||||
self._host = None
|
self._host = None
|
||||||
|
|
||||||
async def connect(self, ip, port):
|
def connect(self, ip, port):
|
||||||
self._host = '{}:{}'.format(ip, port)
|
self._host = '{}:{}'.format(ip, port)
|
||||||
try:
|
try:
|
||||||
await self.conn.connect(ip, port)
|
self.conn.connect(ip, port)
|
||||||
except OSError as e:
|
except OSError as e:
|
||||||
if e.errno == errno.EISCONN:
|
if e.errno == errno.EISCONN:
|
||||||
return # Already connected, no need to re-set everything up
|
return # Already connected, no need to re-set everything up
|
||||||
|
@ -32,26 +32,26 @@ class ConnectionHttp(Connection):
|
||||||
def is_connected(self):
|
def is_connected(self):
|
||||||
return self.conn.is_connected
|
return self.conn.is_connected
|
||||||
|
|
||||||
async def close(self):
|
def close(self):
|
||||||
self.conn.close()
|
self.conn.close()
|
||||||
|
|
||||||
async def recv(self):
|
def recv(self):
|
||||||
while True:
|
while True:
|
||||||
line = await self._read_line()
|
line = self._read_line()
|
||||||
if line.lower().startswith(b'content-length: '):
|
if line.lower().startswith(b'content-length: '):
|
||||||
await self.read(2)
|
self.read(2)
|
||||||
length = int(line[16:-2])
|
length = int(line[16:-2])
|
||||||
return await self.read(length)
|
return self.read(length)
|
||||||
|
|
||||||
async def _read_line(self):
|
def _read_line(self):
|
||||||
newline = ord('\n')
|
newline = ord('\n')
|
||||||
line = await self.read(1)
|
line = self.read(1)
|
||||||
while line[-1] != newline:
|
while line[-1] != newline:
|
||||||
line += await self.read(1)
|
line += self.read(1)
|
||||||
return line
|
return line
|
||||||
|
|
||||||
async def send(self, message):
|
def send(self, message):
|
||||||
await self.write(
|
self.write(
|
||||||
'POST /api HTTP/1.1\r\n'
|
'POST /api HTTP/1.1\r\n'
|
||||||
'Host: {}\r\n'
|
'Host: {}\r\n'
|
||||||
'Content-Type: application/x-www-form-urlencoded\r\n'
|
'Content-Type: application/x-www-form-urlencoded\r\n'
|
||||||
|
|
Loading…
Reference in New Issue
Block a user