gistfile1.rb

# Inside EM::Connection 'receive_data(d)' loop

logger.debug  "New price received"
extraction = proc {
  logger.debug "Extracting price info"
  extract_price_information(response) # Use libxml to match response with a schema and extract values
}
callback = proc { |price| 
  push_to_pusher(price) # Uses pusherapp to broadcast price
}
EM.defer(extraction, callback)