anchor.diff:                       end,
                    [F(K) || K <- Ks],
                    {ok, LKs} = ?MODULE:list_keys(Pid, Bucket),
  -                 ?assertEqual(Ks, lists:sort(LKs))
  +                 ?assertEqual(Ks, lists:sort(LKs)),
  +
  +                 %% Make sure it works with an infinite timeout (will reset the timeout
  +                 %% timer after each packet)
  +                 {ok, LKs2} = ?MODULE:list_keys(Pid, Bucket, infinity),
  +                 ?assertEqual(Ks, lists:sort(LKs2))
                end)},
   
        {"get bucket properties test",
  
positive.code:     [{"ping",
        ?_test( begin
                    {ok, Pid} = start_link(?TEST_IP, ?TEST_PORT),
                    pong = ?MODULE:ping(Pid)
                end)},
       {"set client id",
        ?_test(
  
negative.code: %%      across the cluster.
  %%      See the map/reduce documentation for explanation of behavior.
  mapred_bucket(Pid, Bucket, Query, Timeout) ->
      case mapred_bucket_stream(Pid, Bucket, Query, self(), Timeout) of
          {ok, ReqId} ->
              wait_for_mapred(ReqId, Timeout);
          Error ->
              Error
      end.
  
  %% @spec mapred_bucket_stream(Pid :: pid(),
  %%                            Bucket :: bucket(),
  