cpython: 9c0a00247021 (original) (raw)

Mercurial > cpython

changeset 96331:9c0a00247021

asyncio: Drop some useless code from tasks.py. See also issue 24017. [#24017]

Yury Selivanov yselivanov@sprymix.com
date	Thu, 28 May 2015 10:53:04 -0400
parents	dfe62f685538(current diff)adf72cffceb7(diff)
children	99dcca3466d3
files
diffstat	1 files changed, 2 insertions(+), 7 deletions(-)[+] [-] Lib/asyncio/tasks.py 9

line wrap: on

line diff

--- a/Lib/asyncio/tasks.py +++ b/Lib/asyncio/tasks.py @@ -74,10 +74,7 @@ class Task(futures.Future): super().init(loop=loop) if self._source_traceback: del self._source_traceback[-1]

   if coro.__class__ is types.GeneratorType:[](#l1.7)

```
       self._coro = coro[](#l1.8)
```
```
   else:[](#l1.9)
```

       self._coro = iter(coro)  # Use the iterator just in case.[](#l1.10)

   self._coro = coro[](#l1.11)
   self._fut_waiter = None[](#l1.12)
   self._must_cancel = False[](#l1.13)
   self._loop.call_soon(self._step)[](#l1.14)

@@ -237,10 +234,8 @@ class Task(futures.Future): try: if exc is not None: result = coro.throw(exc)

       elif value is not None:[](#l1.19)

       else:[](#l1.20)
           result = coro.send(value)[](#l1.21)

```
       else:[](#l1.22)
```

           result = coro.send(None)[](#l1.23)
   except StopIteration as exc:[](#l1.24)
       self.set_result(exc.value)[](#l1.25)
   except futures.CancelledError as exc:[](#l1.26)