diff --git a/src/crdt.rs b/src/crdt.rs
index 34bba79b85..e8fcb30cfd 100644
--- a/src/crdt.rs
+++ b/src/crdt.rs
@@ -249,8 +249,6 @@ impl Crdt {
                 .expect("set_index in pub fn broadcast");
         }
 
-        *receive_index += blobs.len() as u64;
-
         Ok(())
     }
 
diff --git a/src/streamer.rs b/src/streamer.rs
index 32f2b9eb22..fb6df26895 100644
--- a/src/streamer.rs
+++ b/src/streamer.rs
@@ -457,6 +457,8 @@ fn broadcast(
         }
     }
 
+    *receive_index += blobs_len as u64;
+
     // Send blobs out from the window
     Crdt::broadcast(crdt, &window, &sock, transmit_index)?;
     Ok(())