diff --git a/StreamReader.cpp b/StreamReader.cpp
index 4dc45e1..532fb16 100644
--- a/StreamReader.cpp
+++ b/StreamReader.cpp
@@ -16,7 +16,7 @@ void StreamReader::run()
 
         // wait for this to unblock before called in event loop
         // Retrieve next buffer
-        PvResult lResult = Stream->RetrieveBuffer(&lBuffer, &lOperationResult, 1000);
+        PvResult lResult = Pipeline->RetrieveNextBuffer(&lBuffer, 1000, &lOperationResult);
         if (lResult.IsOK())
         {
             if (lOperationResult.IsOK())