From 1f7e8ad27952af62e4f7ac0344d8c5c6c2540126 Mon Sep 17 00:00:00 2001
From: Lonami Exo <totufals@hotmail.com>
Date: Mon, 9 Jul 2018 12:49:07 +0200
Subject: [PATCH] Remove missing async/await

---
 telethon/events/__init__.py         |  6 +++---
 telethon/network/connection/http.py | 24 ++++++++++++------------
 2 files changed, 15 insertions(+), 15 deletions(-)

diff --git a/telethon/events/__init__.py b/telethon/events/__init__.py
index 08ef1701..7614dbfe 100644
--- a/telethon/events/__init__.py
+++ b/telethon/events/__init__.py
@@ -18,13 +18,13 @@ class StopPropagation(Exception):
         >>> client = TelegramClient(...)
         >>>
         >>> @client.on(events.NewMessage)
-        ... async def delete(event):
-        ...     await event.delete()
+        ... def delete(event):
+        ...     event.delete()
         ...     # No other event handler will have a chance to handle this event
         ...     raise StopPropagation
         ...
         >>> @client.on(events.NewMessage)
-        ... async def _(event):
+        ... def _(event):
         ...     # Will never be reached, because it is the second handler
         ...     pass
     """
diff --git a/telethon/network/connection/http.py b/telethon/network/connection/http.py
index 955b9ab3..e893486b 100644
--- a/telethon/network/connection/http.py
+++ b/telethon/network/connection/http.py
@@ -16,10 +16,10 @@ class ConnectionHttp(Connection):
         self.write = self.conn.write
         self._host = None
 
-    async def connect(self, ip, port):
+    def connect(self, ip, port):
         self._host = '{}:{}'.format(ip, port)
         try:
-            await self.conn.connect(ip, port)
+            self.conn.connect(ip, port)
         except OSError as e:
             if e.errno == errno.EISCONN:
                 return  # Already connected, no need to re-set everything up
@@ -32,26 +32,26 @@ class ConnectionHttp(Connection):
     def is_connected(self):
         return self.conn.is_connected
 
-    async def close(self):
+    def close(self):
         self.conn.close()
 
-    async def recv(self):
+    def recv(self):
         while True:
-            line = await self._read_line()
+            line = self._read_line()
             if line.lower().startswith(b'content-length: '):
-                await self.read(2)
+                self.read(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')
-        line = await self.read(1)
+        line = self.read(1)
         while line[-1] != newline:
-            line += await self.read(1)
+            line += self.read(1)
         return line
 
-    async def send(self, message):
-        await self.write(
+    def send(self, message):
+        self.write(
             'POST /api HTTP/1.1\r\n'
             'Host: {}\r\n'
             'Content-Type: application/x-www-form-urlencoded\r\n'