lib/woodhouse/extensions/progress.rb in woodhouse-0.1.2 vs lib/woodhouse/extensions/progress.rb in woodhouse-0.1.5
- old
+ new
@@ -140,10 +140,12 @@
StatusTicker.new(self, name, keyw)
end
def update_progress(data)
job = self
- Celluloid::Future.new { progress_sink.update_job(job, data) }
+ sink = progress_sink
+ Celluloid::InternalPool.get { sink.update_job(job, data) }
+ nil
end
def progress_sink
@progress_sink ||= Woodhouse
end