Add missing parameter

include/tao/pq/pipeline.hpp

@@ -5,6 +5,7 @@
 #ifndef TAO_PQ_PIPELINE_HPP
 #define TAO_PQ_PIPELINE_HPP
 
+#include <chrono>
 #include <memory>
 
 #include <tao/pq/transaction_base.hpp>
@@ -40,7 +41,7 @@ namespace tao::pq
       void operator=( pipeline&& ) = delete;
 
       void sync();
-      void consume_sync();
+      void consume_sync( const std::chrono::steady_clock::time_point start = std::chrono::steady_clock::now() );
 
       void finish();
    };

include/tao/pq/transaction_base.hpp

@@ -136,8 +136,6 @@ namespace tao::pq
       }
 
       [[nodiscard]] auto get_result( const std::chrono::steady_clock::time_point start = std::chrono::steady_clock::now() ) -> result;
-
-      // TODO: move this to the pipeline_transaction class
       void consume_pipeline_sync( const std::chrono::steady_clock::time_point start = std::chrono::steady_clock::now() );
    };
 

src/lib/pq/pipeline.cpp

@@ -4,6 +4,8 @@
 
 #include <tao/pq/pipeline.hpp>
 
+#include <chrono>
+
 #include <tao/pq/connection.hpp>
 
 namespace tao::pq
@@ -21,9 +23,9 @@ namespace tao::pq
       connection()->pipeline_sync();
    }
 
-   void pipeline::consume_sync()
+   void pipeline::consume_sync( const std::chrono::steady_clock::time_point start )
    {
-      current_transaction()->consume_pipeline_sync();
+      current_transaction()->consume_pipeline_sync( start );
    }
 
    void pipeline::finish()