lib/polyphony/core/supervisor.rb in polyphony-0.16 vs lib/polyphony/core/supervisor.rb in polyphony-0.17
- old
+ new
@@ -39,10 +39,10 @@
proc.run unless proc.running?
proc
end
def spawn_proc(proc)
- @coprocesses << Object.spawn do |coprocess|
+ @coprocesses << coproc do |coprocess|
proc.call(coprocess)
task_completed(coprocess)
rescue Exception => e
task_completed(coprocess)
end