OMGeeky/flucto-heisskleber
1
0
Fork 0
mirror of https://github.com/OMGeeky/flucto-heisskleber.git synced 2026-01-24 20:30:33 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fixed test for async streamer

Browse Source
This commit is contained in:
Felix Weiler
2023-11-11 20:40:55 +01:00
parent 0ba690cb4a
commit fd18c18d5a
1 changed files with 1 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
tests/test_streamer.py
View File

@@ -28,19 +28,6 @@ def mock_subscriber():
return mock
# @pytest.fixture
# def mock_subscriber():
# mock = MagicMock(spec=AsyncMqttSubscriber)
# async def side_effects():
# yield ("topic1", {"epoch": 1609459200, "data": 1})
# yield ("topic1", {"epoch": 1609459201, "data": 2})
# yield ("topic1", {"epoch": 1609459202, "data": 3})
# # Other messages
# raise EndofData
# mock.receive = AsyncMock(side_effect=side_effects())
# return mock
@pytest.mark.asyncio
@pytest.mark.parametrize(
"resample_rate,expected_length", [(1_000, 5), (2_000, 3), (500, 10)]
@@ -64,7 +51,7 @@ async def test_resampler(mock_subscriber, resample_rate, expected_length):
async for data in resampler.resample():
print(f"resampled data: {data}")
resampled_data.append(data)
if len(resampled_data) == expected_length:
if resampler.buffer.qsize() == 0:
break
print("=======================================================================")
print("\n")