module EventMachine::Protocols::Redis

def self.connect(*args)
  f = Fiber.current
  conn = self.aconnect(*args)
  conn.callback { f.resume(conn) }
  Fiber.yield
end