Eventmachine Client

echo_client.rb

module EchoClient

  ADDRESS = 'localhost'
  PORT = 8081

  class << self
    def get(data)
			result = ""

      EventMachine::run do
        EventMachine::connect(ADDRESS, PORT, EM).execute(data) do |stream|
          result << stream
        end
      end

      result
    end
  end

  private

    module EM

      def receive_data(data)
        @callback.call(data)
        EventMachine::stop_event_loop # ends loop & resumes program flow
      end

      def execute(method, &callback)
        @callback = callback
        send_data(method)
      end

    end

end