Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- require 'rubygems'
- require 'eventmachine'
- require 'pp'
- module HWServer
- def post_init
- puts "HW worker: starting up\n\r"
- end
- def receive_data(data)
- pp "got: #{data}"
- EM.defer(proc{
- sleep(10)
- })
- end
- end
- module HWClient
- def post_init
- send_data("hello")
- end
- end
- # #connects?
- EM::run {
- EM::start_server "127.0.0.1", 8081, HWServer
- EM::start_server "127.0.0.1", 8082, HWServer
- EM::connect "127.0.0.1", 8081, HWClient
- EM::connect "127.0.0.1", 8082, HWClient
- }
Add Comment
Please, Sign In to add comment