Commitaeee419

committed

tcp_charfinder.py with async/await

1 parent890495d commitaeee419Copy full SHA for aeee419

File tree

-6

lines changed

-6

lines changed

Lines changed: 5 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -11,12 +11,11 @@`
`11`	`11`
`12`	`12`	`index=UnicodeNameIndex()# <2>`
`13`	`13`
`14`		`-@asyncio.coroutine`
`15`		`-defhandle_queries(reader,writer):# <3>`
	`14`	`+asyncdefhandle_queries(reader,writer):# <3>`
`16`	`15`	`whileTrue:# <4>`
`17`		`-writer.write(PROMPT)# can'tyield from! # <5>`
`18`		`-yieldfromwriter.drain()# mustyield from! # <6>`
`19`		`-data=yieldfromreader.readline()# <7>`
	`16`	`+writer.write(PROMPT)# can'tawait! # <5>`
	`17`	`+awaitwriter.drain()# mustawait! # <6>`
	`18`	`+data=awaitreader.readline()# <7>`
`20`	`19`	`try:`
`21`	`20`	`query=data.decode().strip()`
`22`	`21`	`exceptUnicodeDecodeError:# <8>`
`@@ -31,7 +30,7 @@ def handle_queries(reader, writer): # <3>`
`31`	`30`	`writer.writelines(line.encode()+CRLFforlineinlines)# <13>`
`32`	`31`	`writer.write(index.status(query,len(lines)).encode()+CRLF)# <14>`
`33`	`32`
`34`		`-yieldfromwriter.drain()# <15>`
	`33`	`+awaitwriter.drain()# <15>`
`35`	`34`	`print('Sent {} results'.format(len(lines)))# <16>`
`36`	`35`
`37`	`36`	`print('Close the client socket')# <17>`

Comments

(0)