diff --git a/streaming/stream_result_future.cc b/streaming/stream_result_future.cc
index d5b01659e2..97c060eff6 100644
--- a/streaming/stream_result_future.cc
+++ b/streaming/stream_result_future.cc
@@ -102,4 +102,9 @@ stream_state stream_result_future::get_current_state() {
     return stream_state(plan_id, description, _coordinator->get_all_session_info());
 }
 
+void stream_result_future::handle_progress(progress_info progress) {
+    _coordinator->update_progress(progress);
+    fire_stream_event(progress_event(plan_id, std::move(progress)));
+}
+
 } // namespace streaming
diff --git a/streaming/stream_result_future.hh b/streaming/stream_result_future.hh
index 91a0ac9a11..6d62efe3ef 100644
--- a/streaming/stream_result_future.hh
+++ b/streaming/stream_result_future.hh
@@ -27,6 +27,7 @@
 #include "streaming/stream_coordinator.hh"
 #include "streaming/stream_event_handler.hh"
 #include "streaming/stream_state.hh"
+#include "streaming/progress_info.hh"
 #include <vector>
 
 namespace streaming {
@@ -125,14 +126,7 @@ public:
 
     void handle_session_complete(shared_ptr<stream_session> session);
 
-#if 0
-    public void handleProgress(ProgressInfo progress)
-    {
-        coordinator.updateProgress(progress);
-        fireStreamEvent(new StreamEvent.ProgressEvent(planId, progress));
-    }
-:A
-#endif
+    void handle_progress(progress_info progress);
 
     template <typename Event>
     void fire_stream_event(Event event);