Rewrite protocol

client/doc/modules/types.rst

@@ -140,8 +140,4 @@ Private definitions
 
 .. currentmodule:: telethon._impl.mtsender.sender
 
-.. autoclass:: AsyncReader
-
-.. autoclass:: AsyncWriter
-
 .. autoclass:: Connector

client/src/telethon/_impl/client/client/net.py

@@ -246,10 +246,9 @@ async def invoke_request(
     sleep_thresh = client._config.flood_sleep_threshold
     rx = client._sender.enqueue(request)
     while True:
-        while not rx.done():
-            await step_sender(client)
+        await step_sender(client)
         try:
-            response = rx.result()
+            response = await rx
             break
         except RpcError as e:
             if e.code == 420 and e.value is not None and e.value < sleep_thresh:

client/src/telethon/_impl/mtsender/__init__.py

@@ -1,8 +1,6 @@
 from .sender import (
     NO_PING_DISCONNECT,
     PING_DELAY,
-    AsyncReader,
-    AsyncWriter,
     Connector,
     Sender,
     connect,
@@ -11,8 +9,6 @@ from .sender import (
 __all__ = [
     "NO_PING_DISCONNECT",
     "PING_DELAY",
-    "AsyncReader",
-    "AsyncWriter",
     "Connector",
     "Sender",
     "connect",