Skip to content

Instantly share code, notes, and snippets.

require 'rubygems'
require 'eventmachine'
module EventMachine
module ChildProcess
def initialize
@buffer = []
end
require 'rubygems'
require 'eventmachine'
module Dtach
def post_init
puts "starting"
end
def receive_data data
require 'mq'
require 'pp'
EM.run {
def log *args
p args
end
mq = MQ.new

EventMachine Notes

Adapted to Markdown format from rom Aman Gupta's gist at: http://gist.github.com/79224

Using:

require 'rubygems'
require 'eventmachine'

EM::run Takes over the Process

require 'rubygems'
require 'eventmachine'
$stdout.sync = true
$stderr.sync = true
EM.run {
EM.add_periodic_timer(0.1) {
$stdout.write "stdout\n"
require 'pp'
require 'uri'
require 'rubygems'
require 'json/ext'
require 'eventmachine'
require 'dnsruby'
require '/Users/djensen/Projects/em-http-request/lib/em-http'
{
"name": "AMQP",
"major-version": 8,
"minor-version": 0,
"port": 5672,
"copyright": [
"Copyright (C) 2008-2009 LShift Ltd, Cohesive Financial Technologies LLC,\n",
"and Rabbit Technologies Ltd\n",
"\n",
"Permission is hereby granted, free of charge, to any person\n",
require 'pp'
require 'uri'
require 'rubygems'
require 'json/ext'
require 'eventmachine'
require 'dnsruby'
require '/Users/djensen/Projects/em-http-request/lib/em-http'
require 'rubygems'
require 'eventmachine'
require 'dnsruby'
#class Dnsruby::SingleResolver
# def get_next_src_port
# @ports ||= 0
# @ports += 1
# p @ports
# return 0
require 'pp'
require 'rubygems'
require 'eventmachine'
module XplaneServer
def post_init
end