class Slack::RealTime::Concurrency::Eventmachine::Socket

def connect
  @driver = ::Faye::WebSocket::Client.new(url, nil, options)
end

def ensure_reactor_running
  return if EventMachine.reactor_running?
  reactor = Thread.new { EventMachine.run }
  Thread.pass until EventMachine.reactor_running?
  reactor
end

def send_data(message)
  driver.send(message)
end

def start_async
  thread = ensure_reactor_running
  yield self if block_given?
  thread
end