Sinatra + Fibers + EventMachine

Question

Я хотел бы знать, чтобы приостановить корневое волокно в рубине (если возможно).

У меня есть это приложение Sinatra, и я делаю асинхронные вызовы внешнему API с EventMachine. Я не хочу отвечать клиенту, пока апи не ответит мне.

Например, спящее корневое волокно в Синатре до тех пор, пока обратный вызов EventMachine не разбудит его.

Спасибо.

Answer 1

get '/some/route/' do 
    fib = Fiber.current 
    req = EM::SomeNonBlokingLib.request 
    req.callback do |response| 
    fib.resume(response) 
    end 
    req.errback do |err| 
    fib.resume(err) 
    end 
    Fiber.yield 
end 

EDIT

В вашем случае вы должны порождать Волокно для каждого запроса. Так. Во-первых, создать Rack конфигурационный файл и добавить некоторые магии:

# config.ru 
BOOT_PATH = File.expand_path('../http.rb', __FILE__) 
require BOOT_PATH 

class FiberSpawn 
    def initialize(app) 
    @app = app 
    end 

    def call(env) 
    fib = Fiber.new do 
     res = @app.call(env) 
     env['async.callback'].call(res) 
    end 
    EM.next_tick{ fib.resume } 
    throw :async 
    end 
end 

use FiberSpawn 
run Http 

Тогда ваш HTTP Синатра приложение:

# http.rb 
require 'sinatra' 
require 'fiber' 

class Http < Sinatra::Base 
    get '/' do 
    f = Fiber.current 
    EM.add_timer(1) do 
     f.resume("Hello World") 
    end 
    Fiber.yield 
    end 
end 

Теперь вы можете запустить его под thin, например:

> thin start -R config.ru 

Тогда, если вы посетит locakhost:3000, вы увидите сообщение Hello World