Difference between asyncio stream and synchronous stream for json output to a client

[srinivasa rao pedada]

Code: Select all

response = {
'error': 'invalid request',
'status': 'retry'
}

synchronous side:

Code: Select all

conn.send('HTTP/1.1 200 OK\n')
conn.send('Content-Type: application/json\n')
conn.send('Connection: close\n\n')
conn.sendall(ujson.dumps(response ))

asyncio side:

Code: Select all

swriter.write(ujson.dumps(response ))
await swriter.drain()

Client was to able to read json response in synchronous way but reading failed in asyncio, Where is the error?

[pythoncoder]

It's hard to debug asynchronous code without having the full context (and I'm not a web programmer). But there's nothing wrong with the two lines of code you've shown us

Is it possible that other tasks are hogging CPU time causing gaps in communication with consequent timeouts by the receiver?

[srinivasa rao pedada]

got the error:

Code: Select all

asyncio.wait_for(sreader.readline(), self.timeout)

------> changed to

Code: Select all

asyncio.wait_for(sreader.read(2048), self.timeout)

. Now client is recieving json output immediately after closing the socket. Like you said its a timing issue, thank you sir.