(
self, get_func: typing.Callable[[BytesQueueBuffer], bytes]
)
| 148 | ) |
| 149 | @pytest.mark.limit_memory("10.01 MB", current_thread_only=True) |
| 150 | def test_memory_usage_single_chunk( |
| 151 | self, get_func: typing.Callable[[BytesQueueBuffer], bytes] |
| 152 | ) -> None: |
| 153 | buffer = BytesQueueBuffer() |
| 154 | chunk = bytes(10 * 2**20) # 10 MiB |
| 155 | buffer.put(chunk) |
| 156 | assert get_func(buffer) is chunk |
| 157 | |
| 158 | @pytest.mark.parametrize( |
| 159 | "finish_with_get_all", |
nothing calls this directly
no test coverage detected