src/bin/test_chunk_speed2.rs: test max chunk size

This commit is contained in:
Dietmar Maurer 2019-05-19 11:09:02 +02:00
parent ff77dbbea3
commit 751030aa7c
1 changed files with 1 additions and 0 deletions

View File

@ -33,6 +33,7 @@ fn main() {
chunk_stream chunk_stream
.for_each(move |chunk| { .for_each(move |chunk| {
if chunk.len() > 16*1024*1024 { panic!("Chunk too large {}", chunk.len()); }
repeat.fetch_add(1, Ordering::SeqCst); repeat.fetch_add(1, Ordering::SeqCst);
stream_len.fetch_add(chunk.len(), Ordering::SeqCst); stream_len.fetch_add(chunk.len(), Ordering::SeqCst);
println!("Got chunk {}", chunk.len()); println!("Got chunk {}", chunk.len());