We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7763e8e commit 3941670Copy full SHA for 3941670
examples/bench/server.py
@@ -2,6 +2,7 @@
2
import asyncio
3
import gc
4
import uvloop
5
+import socket as socket_module
6
7
from socket import *
8
@@ -41,14 +42,15 @@ async def echo_client(loop, client):
41
42
43
async def echo_client_streams(reader, writer):
44
sock = writer.get_extra_info('socket')
45
+ if hasattr(socket_module, 'TCP_NODELAY'):
46
+ sock.setsockopt(IPPROTO_TCP, TCP_NODELAY, 1)
47
if PRINT:
48
print('Connection from', sock.getpeername())
49
while True:
- data = await reader.read(10000)
50
+ data = await reader.read(100000)
51
if not data:
52
break
53
writer.write(data)
- await writer.drain()
54
55
print('Connection closed')
56
writer.close()
0 commit comments