eventmachine

    0热度

    1回答

    我使用的是Rails 3.2,我想要一个使用rails runner来监视TweetStream的辅助进程,不幸的是我的模型在我使用调试器访问它们之前似乎是空的。什么会造成这种情况?我需要重新连接到我的数据库吗?这与EventMachine有关吗? 更具体地说,我有: charity = Charity.find_by_blah(blah) if charity.nil? bindin

    4热度

    2回答

    我正在构建一个使用TweetStream(使用EventMachine监听Tweets)的Sinatra应用程序。我还希望该应用能够像普通的Sinatra应用一样提供页面,但是它似乎像Sinatra在“倾听”Tweets时不能“听”页面请求。 这是我可以通过使用不同的服务器或以不同的方式构建我的应用程序来解决?我试过使用WebBrick和Thin。 这里基本上是我在做什么: class App <

    2热度

    1回答

    我知道Thin构建在EventMachine之上,它提供了异步IO。如果我使用RoR或Sinatra之类的机架框架并执行一些数据库调用(不使用任何特殊库),是否会阻止主事件循环(因为我使用Thin作为Web服务器)? 感谢

    0热度

    2回答

    我正在研究一个基于eventmachine的应用程序,该应用程序会定期轮询MongoDB存储文档的更改。 简化代码片段可能看起来像: require 'rubygems' require 'eventmachine' require 'em-mongo' require 'bson' EM.run { @db = EM::Mongo::Connection.new('loc

    -1热度

    2回答

    我正在尝试创建一个将返回有关EventMachine服务器的统计信息的Sinatra服务器。也就是说,我运行: EventMachine.run do server = EventMachine.start_server 'localhost', 3333, MyApp dispatch = Rack::Builder.app do map '/' do

    0热度

    1回答

    有没有人有任何构建使用em-synchrony和receive_data的自定义网络客户端的示例?

    2热度

    1回答

    我有问题了解使用带有eventmachine的光纤模型调用外部API时发生了什么。我有这样的代码在西纳特拉: get '/' do conn = Faraday.new 'http://slow-api-call' do |con| con.adapter :em_http end resp = conn.get resp.on_complete

    0热度

    1回答

    调用周期性定时器,当块内发生错误时,更改此周期性定时器延迟。我可以使用定期计时器还是最好的方法是add_timer? 嗨,我想这样做: EventMachine.run EventMachine.add_periodic_timer 1 //read from a input //if error set timer to 20s //if ok set t

    0热度

    1回答

    所以基本上我的目标是获得某种轻量级ruby守护进程(或sidekiq/resque worker),它处理作业并通过http通知其他应用程序。该应用程序本身不需要接收http请求,所以没有机架保持尽可能轻的重量。我可以在循环{} 几乎可以运行的红宝石代码所以试图不使用EventMachine的反应堆模式和使用光纤方法。我在哪里会把EM.run或EM.stop放在这个上下文中Thread.new {

    0热度

    1回答

    在ruby标准库中,popen返回一个有pid方法的对象, 在eventmachine中,popen返回一个不包含进程id信息的Connection对象。 演示这里代码: require 'eventmachine' def work s = EM.popen('ls') puts s.pid # how to get new process's pid? end E