equal
deleted
inserted
replaced
135 read_sizes=strategies.data(), |
135 read_sizes=strategies.data(), |
136 ) |
136 ) |
137 def test_buffer_source_read_variance( |
137 def test_buffer_source_read_variance( |
138 self, original, level, source_read_size, read_sizes |
138 self, original, level, source_read_size, read_sizes |
139 ): |
139 ): |
140 |
|
141 refctx = zstd.ZstdCompressor(level=level) |
140 refctx = zstd.ZstdCompressor(level=level) |
142 ref_frame = refctx.compress(original) |
141 ref_frame = refctx.compress(original) |
143 |
142 |
144 cctx = zstd.ZstdCompressor(level=level) |
143 cctx = zstd.ZstdCompressor(level=level) |
145 with cctx.stream_reader( |
144 with cctx.stream_reader( |
201 ), |
200 ), |
202 ) |
201 ) |
203 def test_buffer_source_readinto( |
202 def test_buffer_source_readinto( |
204 self, original, level, source_read_size, read_size |
203 self, original, level, source_read_size, read_size |
205 ): |
204 ): |
206 |
|
207 refctx = zstd.ZstdCompressor(level=level) |
205 refctx = zstd.ZstdCompressor(level=level) |
208 ref_frame = refctx.compress(original) |
206 ref_frame = refctx.compress(original) |
209 |
207 |
210 cctx = zstd.ZstdCompressor(level=level) |
208 cctx = zstd.ZstdCompressor(level=level) |
211 with cctx.stream_reader( |
209 with cctx.stream_reader( |
271 read_sizes=strategies.data(), |
269 read_sizes=strategies.data(), |
272 ) |
270 ) |
273 def test_buffer_source_readinto_variance( |
271 def test_buffer_source_readinto_variance( |
274 self, original, level, source_read_size, read_sizes |
272 self, original, level, source_read_size, read_sizes |
275 ): |
273 ): |
276 |
|
277 refctx = zstd.ZstdCompressor(level=level) |
274 refctx = zstd.ZstdCompressor(level=level) |
278 ref_frame = refctx.compress(original) |
275 ref_frame = refctx.compress(original) |
279 |
276 |
280 cctx = zstd.ZstdCompressor(level=level) |
277 cctx = zstd.ZstdCompressor(level=level) |
281 with cctx.stream_reader( |
278 with cctx.stream_reader( |
408 read_sizes=strategies.data(), |
405 read_sizes=strategies.data(), |
409 ) |
406 ) |
410 def test_buffer_source_read1_variance( |
407 def test_buffer_source_read1_variance( |
411 self, original, level, source_read_size, read_sizes |
408 self, original, level, source_read_size, read_sizes |
412 ): |
409 ): |
413 |
|
414 refctx = zstd.ZstdCompressor(level=level) |
410 refctx = zstd.ZstdCompressor(level=level) |
415 ref_frame = refctx.compress(original) |
411 ref_frame = refctx.compress(original) |
416 |
412 |
417 cctx = zstd.ZstdCompressor(level=level) |
413 cctx = zstd.ZstdCompressor(level=level) |
418 with cctx.stream_reader( |
414 with cctx.stream_reader( |
549 read_sizes=strategies.data(), |
545 read_sizes=strategies.data(), |
550 ) |
546 ) |
551 def test_buffer_source_readinto1_variance( |
547 def test_buffer_source_readinto1_variance( |
552 self, original, level, source_read_size, read_sizes |
548 self, original, level, source_read_size, read_sizes |
553 ): |
549 ): |
554 |
|
555 refctx = zstd.ZstdCompressor(level=level) |
550 refctx = zstd.ZstdCompressor(level=level) |
556 ref_frame = refctx.compress(original) |
551 ref_frame = refctx.compress(original) |
557 |
552 |
558 cctx = zstd.ZstdCompressor(level=level) |
553 cctx = zstd.ZstdCompressor(level=level) |
559 with cctx.stream_reader( |
554 with cctx.stream_reader( |