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

Fix test_utils_middlewares for 3.5.

This commit is contained in:
Andrey Rakhmatullin 2020-05-21 16:09:03 +05:00
parent 5b4adffabf
commit 3bacf8e421
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/test_utils_middlewares.py
View File

@ -4,7 +4,6 @@ import sys
from pytest import mark
from twisted.trial import unittest
from scrapy.utils.asyncgen import as_async_generator, collect_asyncgen
from scrapy.utils.defer import deferred_f_from_coro_f
from scrapy.utils.middlewares import process_iterable_helper
@ -58,6 +57,7 @@ class ProcessIterableHelperAsyncTest(unittest.TestCase):
@deferred_f_from_coro_f
async def test_async_in_predicate(self):
from scrapy.utils.asyncgen import as_async_generator, collect_asyncgen
iterable1 = as_async_generator([1, 2, 3])
iterable2 = process_iterable_helper(iterable1, in_predicate=predicate1)
self.assertIsInstance(iterable2, collections.abc.AsyncIterable)
@ -66,6 +66,7 @@ class ProcessIterableHelperAsyncTest(unittest.TestCase):
@deferred_f_from_coro_f
async def test_async_out_predicate(self):
from scrapy.utils.asyncgen import as_async_generator, collect_asyncgen
iterable1 = as_async_generator([1, 2, 10, 3, 15])
iterable2 = process_iterable_helper(iterable1, out_predicate=predicate2)
self.assertIsInstance(iterable2, collections.abc.AsyncIterable)
@ -74,6 +75,7 @@ class ProcessIterableHelperAsyncTest(unittest.TestCase):
@deferred_f_from_coro_f
async def test_async_processor(self):
from scrapy.utils.asyncgen import as_async_generator, collect_asyncgen
iterable1 = as_async_generator([1, 2, 3])
iterable2 = process_iterable_helper(iterable1, processor=processor)
self.assertIsInstance(iterable2, collections.abc.AsyncIterable)
@ -82,6 +84,7 @@ class ProcessIterableHelperAsyncTest(unittest.TestCase):
@deferred_f_from_coro_f
async def test_async_combined(self):
from scrapy.utils.asyncgen import as_async_generator, collect_asyncgen
iterable1 = as_async_generator([1, 2, 10, 3, 6, 18, 5, 15])
iterable2 = process_iterable_helper(iterable1, in_predicate=predicate1,
out_predicate=predicate2, processor=processor)