Commit1bbb7ab

committed

flags2_asyncio_executor.py closing http request\n\nSometime raises RuntimeError: Event loop is closed

1 parent90daf6e commit1bbb7abCopy full SHA for 1bbb7ab

File tree

+12

-9

lines changed

+12

-9

lines changed

Lines changed: 12 additions & 9 deletions

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@`
`6`	`6`
`7`	`7`	`importasyncio`
`8`	`8`	`importcollections`
	`9`	`+importcontextlib`
`9`	`10`
`10`	`11`	`importaiohttp`
`11`	`12`	`fromaiohttpimportweb`
`@@ -28,15 +29,17 @@ def __init__(self, country_code):`
`28`	`29`	`defget_flag(base_url,cc):`
`29`	`30`	`url='{}/{cc}/{cc}.gif'.format(base_url,cc=cc.lower())`
`30`	`31`	`resp=yieldfromaiohttp.request('GET',url)`
`31`		`-ifresp.status==200:`
`32`		`-image=yieldfromresp.read()`
`33`		`-returnimage`
`34`		`-elifresp.status==404:`
`35`		`-raiseweb.HTTPNotFound()`
`36`		`-else:`
`37`		`-raiseaiohttp.HttpProcessingError(`
`38`		`-code=resp.status,message=resp.reason,`
`39`		`-headers=resp.headers)`
	`32`	`+withcontextlib.closing(resp):`
	`33`	`+ifresp.status==200:`
	`34`	`+image=yieldfromresp.read()`
	`35`	`+returnimage`
	`36`	`+elifresp.status==404:`
	`37`	`+raiseweb.HTTPNotFound()`
	`38`	`+else:`
	`39`	`+raiseaiohttp.HttpProcessingError(`
	`40`	`+code=resp.status,message=resp.reason,`
	`41`	`+headers=resp.headers)`
	`42`	`+`
`40`	`43`
`41`	`44`	`# BEGIN FLAGS2_ASYNCIO_EXECUTOR`
`42`	`45`	`@asyncio.coroutine`

Comments

(0)