Add New Comment

Subscribe:  This Thread

Go to:  My Comments ·  Community Page

Sort thread by: Hot comments Best comments Newest first Oldest first

Viewing 4 Comments

• 
  • 
  • 
  

  • Permalink
  • Admin
  • • Remove Post
    • Block email
    • Block IP address

  Johannes Fahrenkrug 4 months ago 1 point

  Please login to rate.

  Do you already have an account? Log in and claim this comment.

  Very cool, Elias!
  reply  edit  reblog  flag
  http://blog.springenwerk.com/ /people/b0c68cd8ea105ef0e8fbe8f7e0fdbf5e/
• 
  • 
  • 
  

  • Permalink
  • Admin
  • • Remove Post
    • Block username
    • Block email
    • Block IP address

  pabloponsbordes 4 months ago 1 point

  Please login to rate.

  Do you already have an account? Log in and claim this comment.

  This is amazing, congratulation for your work it looks really great.
  I will make some experiment with it.
  reply  edit  reblog  flag
  1 /people/pabloponsbordes/ /people/pabloponsbordes/following/
• 
  • 
  • 
  

  • Permalink
  • Admin
  • • Remove Post
    • Block email
    • Block IP address

  Luca Bonifazi 3 months ago 1 point

  Please login to rate.

  Do you already have an account? Log in and claim this comment.

  I've tried async_sinatra on a rails metal class instead of Tornado and without juggernaut.
  It worked, not well coded, just a proof of concept.
  Some work to do on AppController.j for the cappuccino app, just json messages parsing and connection urls.
  
  Here's the metal code
  
  require 'sinatra/async'
  #thread safe notificator
  class Looper
  include EM::Deferrable
  def initialize
  @waiters = EM::Queue.new
  end
  def add_listener(listener)
  @waiters.push(listener)
  end
  def notify(x)
  res = x.to_json
  @waiters.size().times do
  @waiters.pop{ |w|
  w.body res
  }
  end
  end
  end
  
  class SinatraTest < Sinatra::Base
  register Sinatra::Async
  enable :show_exceptions
  @@df = Looper.new
  @@df.callback {|x|
  @@df.notify(x)
  }
  def self.restart_looper
  @@df = Looper.new
  @@df.callback {|x|
  @@df.notify(x)
  }
  end
  apost '/message' do
  message={:type => params["type"],:sender => params["sender"],:body => params["body"]}
  body ""
  @@df.set_deferred_status :succeeded, message
  SinatraTest.restart_looper
  end
  apost '/color' do
  color = {:type => params["type"],:color => params["color"]}
  body ""
  @@df.set_deferred_status :succeeded, color
  SinatraTest.restart_looper
  end
  apost '/updates' do
  @@df.add_listener(self)
  end
  end
  reply  edit  reblog  flag
  /people/c29b3d3e2ebfc7b9b806a43ea5ee6fd8/
• 
  • 
  • 
  

  • Parent
  • Permalink
  • Admin
  • • Remove Post
    • Block email
    • Block IP address

  Luca Bonifazi 3 months ago 1 point

  Please login to rate.

  Do you already have an account? Log in and claim this comment.

  It needs thin for async.
  script/server thin
  reply  edit  reblog  flag
  /people/c29b3d3e2ebfc7b9b806a43ea5ee6fd8/

Add New Comment

Trackbacks