diff --git a/lib/rbbt/rest/workflow/jobs.rb b/lib/rbbt/rest/workflow/jobs.rb
index <HASH>..<HASH> 100644
--- a/lib/rbbt/rest/workflow/jobs.rb
+++ b/lib/rbbt/rest/workflow/jobs.rb
@@ -205,6 +205,11 @@ module WorkflowRESTHelpers
 
     headers "RBBT-STREAMING-JOB-URL" => to(job_url) if job_url
 
+    ConcurrentStream.setup(sout, :pair => s, :autojoin => true) do
+      job.abort unless job.done?
+    end
+
+
     halt 200, sout
   end
Abort streaming jobs when client breaks connection