diff --git a/Detectors/TOF/workflow/src/ClusterReaderSpec.cxx b/Detectors/TOF/workflow/src/ClusterReaderSpec.cxx
index e565b335ffabb..c27b8c704b508 100644
--- a/Detectors/TOF/workflow/src/ClusterReaderSpec.cxx
+++ b/Detectors/TOF/workflow/src/ClusterReaderSpec.cxx
@@ -72,6 +72,7 @@ void ClusterReader::run(ProcessingContext& pc)
   }
 
   mState = 2;
+  pc.services().get<ControlService>().endOfStream();
   pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);
 }
 
diff --git a/Detectors/TPC/workflow/src/TrackReaderSpec.cxx b/Detectors/TPC/workflow/src/TrackReaderSpec.cxx
index ca75579c157fb..4fa81996cceb4 100644
--- a/Detectors/TPC/workflow/src/TrackReaderSpec.cxx
+++ b/Detectors/TPC/workflow/src/TrackReaderSpec.cxx
@@ -51,6 +51,7 @@ void TrackReader::run(ProcessingContext& pc)
   }
 
   mFinished = true;
+  pc.services().get<ControlService>().endOfStream();
   pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);
 }