class Redis::Distributed

def _bpop(cmd, args) 

def _bpop(cmd, args)
  options = {}
  case args.last
  when Hash
    options = args.pop
  when Integer
    # Issue deprecation notice in obnoxious mode...
    options[:timeout] = args.pop
  end
  if args.size > 1
    # Issue deprecation notice in obnoxious mode...
  end
  keys = args.flatten
  ensure_same_node(cmd, keys) do |node|
    node.__send__(cmd, keys, options)
  end
end