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

def connect
  @driver = Client.new(url, nil, options.merge(logger: logger))
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)
  logger.debug("#{self.class}##{__method__}") { message }
  driver.send(message)
end

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