class EM::Mongo::Connection

def initialize(host = DEFAULT_IP, port = DEFAULT_PORT, timeout = nil, opts = {})
  f = Fiber.current
  @em_connection = EMConnection.connect(host, port, timeout, opts)
  @db = {}
  # establish connection before returning
  EM.next_tick { f.resume }
  Fiber.yield
end