faye em

gistfile1.rb

# server at 8081
require 'rubygems'
require 'faye/websocket'

app = lambda do |env|
	ws = Faye::WebSocket.new(env)

	ws.onmessage = lambda do |event|
		puts event.data
		if event.data == 'started'
			ws.send('ping')
		end
	end

	ws.onclose = lambda do |event|
		puts "closed"
		ws = nil
	end

	ws.rack_response
end

Faye::WebSocket.load_adapter('thin')
Rack::Handler::Thin.run(app, :Port => 8081)


# client
require 'faye/websocket'
require 'eventmachine'

EM.run {
  ws = Faye::WebSocket::Client.new('ws://0.0.0.0:8081')

  ws.onopen = lambda do |event|
		ws.send("started")
  end

  ws.onmessage = lambda do |event|
		puts event.data
  end

  ws.onclose = lambda do |event|
    p [:close, event.code, event.reason]
    ws = nil
  end
}