Commita6492e9

committed

add wrapper

1 parent2999e02 commita6492e9Copy full SHA for a6492e9

File tree

-5

lines changed

-5

lines changed

Lines changed: 5 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,6 @@`
`25`	`25`	`from .importexceptions`
`26`	`26`	`from .importfutures`
`27`	`27`	`from .importtimeouts`
`28`		`-from .coroutinesimport_is_coroutine`
`29`	`28`
`30`	`29`	`# Helper to generate new task names`
`31`	`30`	`# This uses itertools.count() instead of a "+= 1" operation because the latter`
`@@ -654,17 +653,18 @@ def ensure_future(coro_or_future, *, loop=None):`
`654`	`653`	`raise`
`655`	`654`
`656`	`655`
`657`		`-@types.coroutine`
`658`		`-def_wrap_awaitable(awaitable):`
	`656`	`+asyncdef_wrap_awaitable(awaitable):`
`659`	`657`	`"""Helper for asyncio.ensure_future().`
`660`	`658`
`661`	`659`	`Wraps awaitable (an object with __await__) into a coroutine`
`662`	`660`	`that will later be wrapped in a Task by ensure_future().`
`663`	`661`	`"""`
`664`		`-return (yieldfromawaitable.__await__())`
`665`	`662`
`666`		`-_wrap_awaitable._is_coroutine=_is_coroutine`
	`663`	`+@types.coroutine`
	`664`	`+defwrapper(awaitable):`
	`665`	`+return (yieldfromawaitable.__await__())`
`667`	`666`
	`667`	`+returnawaitwrapper(awaitable)`
`668`	`668`
`669`	`669`	`class_GatheringFuture(futures.Future):`
`670`	`670`	`"""Helper for gather().`

Comments

(0)