# File lib/em/threaded_resource.rb, line 68 def dispatch completion = EM::Completion.new @queue << lambda do begin result = yield @resource completion.succeed result rescue Exception => e completion.fail e end end completion end