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: 
  -type address() :: string() | atom() | ip_address().
  -type portnum() :: non_neg_integer().
  -type client_id() :: binary().
  -type bucket() :: binary().
  -type key() :: binary().
  
negative.code: %% @doc Perform a map/reduce job across the cluster.
  %%      See the map/reduce documentation for explanation of behavior.
  mapred(Pid, Inputs, Query, Timeout) ->
      case mapred_stream(Pid, Inputs, Query, self(), Timeout) of
          {ok, ReqId} ->
              wait_for_mapred(ReqId, Timeout);
          Error ->
              Error
      end.
  
  %% @spec mapred_stream(Pid :: pid(),
  %%                     Inputs :: list(),
  