Sort fan out results before comparison in test
parent
bfe99f29b8
commit
1c63bb6130
|
@ -281,12 +281,7 @@ async def stream_from_aio(
|
||||||
# ``.subscribe()`` fan out case.
|
# ``.subscribe()`` fan out case.
|
||||||
doubled = list(itertools.chain(*zip(expect, expect)))
|
doubled = list(itertools.chain(*zip(expect, expect)))
|
||||||
expect = doubled[:len(pulled)]
|
expect = doubled[:len(pulled)]
|
||||||
if pulled != expect:
|
assert list(sorted(pulled)) == expect
|
||||||
print(
|
|
||||||
f'uhhh pulled is {pulled}\n',
|
|
||||||
f'uhhh expect is {expect}\n',
|
|
||||||
)
|
|
||||||
assert pulled == expect
|
|
||||||
|
|
||||||
else:
|
else:
|
||||||
assert pulled == expect
|
assert pulled == expect
|
||||||
|
|
Loading…
Reference in New Issue