diff --git a/yama/src/remote/requester.rs b/yama/src/remote/requester.rs
index c39f2f6..142d540 100644
--- a/yama/src/remote/requester.rs
+++ b/yama/src/remote/requester.rs
@@ -401,6 +401,7 @@ impl RawPile for Requester {
                         // Either the pipeline is stopping or we are too busy to accept new chunks,
                         // so only process responses.
                         let resp = response_rx.recv().unwrap();
+                        in_flight_writes -= 1;
                         match resp {
                             ResponseBody::Success => {
                                 // nop