Commit56094ef

committed

flags2_asyncio with closing rehttp response

1 parent333615d commit56094efCopy full SHA for 56094ef

File tree

-8

lines changed

-8

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@`
`18`	`18`	`# BEGIN FLAGS2_ASYNCIO_TOP`
`19`	`19`	`importasyncio`
`20`	`20`	`importcollections`
`21`		`-fromcontextlibimportclosing`
	`21`	`+importcontextlib`
`22`	`22`
`23`	`23`	`importaiohttp`
`24`	`24`	`fromaiohttpimportweb`
`@@ -41,7 +41,7 @@ def __init__(self, country_code):`
`41`	`41`	`defget_flag(base_url,cc):# <2>`
`42`	`42`	`url='{}/{cc}/{cc}.gif'.format(base_url,cc=cc.lower())`
`43`	`43`	`resp=yieldfromaiohttp.request('GET',url)`
`44`		`-withclosing(resp):`
	`44`	`+withcontextlib.closing(resp):`
`45`	`45`	`ifresp.status==200:`
`46`	`46`	`image=yieldfromresp.read()`
`47`	`47`	`returnimage`

Lines changed: 4 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -81,16 +81,14 @@ def downloader_coro(cc_list, base_url, verbose, concur_req):`
`81`	`81`	`error_msg=exc.__cause__.args[0]`
`82`	`82`	`exceptIndexError:`
`83`	`83`	`error_msg=exc.__cause__.__class__.__name__`
	`84`	`+ifverboseanderror_msg:`
	`85`	`+msg='*** Error for {}: {}'`
	`86`	`+print(msg.format(country_code,error_msg))`
	`87`	`+status=HTTPStatus.error`
`84`	`88`	`else:`
`85`		`-error_msg=''`
`86`	`89`	`status=res.status`
`87`	`90`
`88`		`-iferror_msg:`
`89`		`-status=HTTPStatus.error`
`90`	`91`	`counter[status]+=1`
`91`		`-ifverboseanderror_msg:`
`92`		`-msg='*** Error for {}: {}'`
`93`		`-print(msg.format(country_code,error_msg))`
`94`	`92`
`95`	`93`	`returncounter`
`96`	`94`

Comments

(0)