adjusted test target
This commit is contained in:
parent
70df7911b9
commit
da2dce762b
@ -35,7 +35,7 @@ def test_stream_buffer_catches_type_error(func, inputs, outputs):
|
|||||||
def test_flat_stream_buffer(func, inputs, outputs, buffer_size):
|
def test_flat_stream_buffer(func, inputs, outputs, buffer_size):
|
||||||
flat_stream_buffer = FlatStreamBuffer(lift(func), buffer_size=buffer_size)
|
flat_stream_buffer = FlatStreamBuffer(lift(func), buffer_size=buffer_size)
|
||||||
|
|
||||||
assert list(flat_stream_buffer(inputs)) == lflatten(outputs)
|
assert list(flat_stream_buffer(inputs)) == outputs
|
||||||
assert list(flat_stream_buffer([])) == []
|
assert list(flat_stream_buffer([])) == []
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user