Fix issue when, under heavy load, pewpew panicswith message "found a …

…left over previous bucket"

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "pewpew"
-version = "0.5.6-beta3"
+version = "0.5.6-beta4"
 edition = "2018"
 default-run = "pewpew"
 publish = false

README.md

@@ -14,6 +14,7 @@ Bugfix:
 - Fix regression introduced in v0.5.5 where specifying a `provider` multiple times in a `provides` would only use the last specified one.
 - Fix bug where non-ascii characters could cause an error reading a file when using the `line` (default) `format`.
 - Fix bug where the `line` `format` of a file provider would incorrectly parse files with lines longer than 8KB.
+- Fix issue when, under heavy load, pewpew panics with message "found a left over previous bucket".
 
 ### v0.5.5
 Changes:

src/stats.rs

@@ -419,7 +419,6 @@ where
                 i
             }
         };
-        self.check_current_bucket();
         self.current.append(stat, index);
         if let Some(new_tag) = new_tag {
             let a = self.write_file_message(&FileMessage::Tags(new_tag));
@@ -834,16 +833,15 @@ where
             }
             join_all(futures).then(|_| Ok::<_, TestError>(()))
         },
-    )
-    .join(print_stats)
-    .map(|_| TestEndReason::Completed)
-    .or_else(move |e| test_killer.send(Err(e.clone())).then(move |_| Err(e)))
-    .select(test_complete.map(|e| *e).map_err(|e| (&*e).clone()))
-    // .map_err(|e| e.0)
-    // .and_then(move |(b, _)| stats2.lock().persist(console4()).map(move |_| b))
-    .then(move |_| {
-        let mut stats = stats3.lock();
-        stats.close_out_bucket(true).then(|_| Ok(()))
-    });
-    Ok((tx, receiver))
+    );
+    let task = print_stats
+        .join(receiver)
+        .map(|_| TestEndReason::Completed)
+        .or_else(move |e| test_killer.send(Err(e.clone())).then(move |_| Err(e)))
+        .select(test_complete.map(|e| *e).map_err(|e| (&*e).clone()))
+        .then(move |_| {
+            let mut stats = stats3.lock();
+            stats.close_out_bucket(true).then(|_| Ok(()))
+        });
+    Ok((tx, task))
 }