RomanNum3ral
/
scrapy
mirror of https://github.com/scrapy/scrapy.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove some unneeded code from _AsyncCooperatorAdapter.

This commit is contained in:
Andrey Rakhmatullin 2021-03-26 20:17:41 +05:00
parent 7b515a0485
commit b5f501df7b
1 changed files with 0 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
scrapy/utils/defer.py
View File

@ -136,8 +136,6 @@ class _AsyncCooperatorAdapter:
self.anext_deferred = None
result = self.callable(result, *self.callable_args, **self.callable_kwargs)
d = self.waiting_deferreds.pop(0)
if d.called:
raise ValueError('Deferred in waiting_deferreds already called')
if isinstance(result, defer.Deferred):
result.chainDeferred(d)
else:
@ -152,8 +150,6 @@ class _AsyncCooperatorAdapter:
failure.trap(StopAsyncIteration)
self.finished = True
for d in self.waiting_deferreds:
if d.called:
raise ValueError('Deferred in waiting_deferreds already called')
d.callback(None)
def _call_anext(self):
@ -162,9 +158,6 @@ class _AsyncCooperatorAdapter:
self.anext_deferred = deferred_from_coro(self.aiterator.__anext__())
self.anext_deferred.addCallbacks(self._callback, self._errback)
def __iter__(self):
return self
def __next__(self):
# This puts a new Deferred into self.waiting_deferreds and returns it.
# It also calls __anext__() if needed.