class Mysql2::EM::Client

def close(*args)
  @watch.detach if @watch && @watch.watching?
  super(*args)
end