diff --git a/radio/processor/src/Buffer.tcc b/radio/processor/src/Buffer.tcc
index 70821bb..d1b18e8 100644
--- a/radio/processor/src/Buffer.tcc
+++ b/radio/processor/src/Buffer.tcc
@@ -122,6 +122,7 @@ size_t Buffer<T>::read(T* pData, size_t len)
 		pData += actual_len;
 		numRead += actual_len;
 	}
+	consume(numRead);
 	return numRead;
 
 }