event_machine_server.rb

require "eventmachine"

module Thrift
  class EventMachineServer < BaseServer

    def initialize(processor)
      @em = Class.new(EM::Connection) do
        class << self
          attr_accessor :processor
        end

        def receive_data(data)
          request = StringIO.new data
          response = StringIO.new

          transport = Thrift::IOStreamTransport.new request, response
          protocol = Thrift::BinaryProtocol.new transport

          self.class.processor.process protocol, protocol
          send_data response.string
        end
      end

      @em.processor = processor
    end

    def serve
      EM.run do
        EM.start_server "0.0.0.0", 9090, @em
      end
    end
  end
end