diff --git a/src/batched_accumulator.rs b/src/batched_accumulator.rs index c0b1c87..ca01671 100644 --- a/src/batched_accumulator.rs +++ b/src/batched_accumulator.rs @@ -579,7 +579,7 @@ impl BachedAccumulator { } }; - output_map.flush_async()?; + output_map.flush()?; Ok(()) }