anchor.diff:  %% internal functions
   %% ====================================================================
   
  +%% @private
  +%% Parse options
  +parse_options([], State) ->
  +    State;
  +parse_options([queue_if_disconnected|Options], State) ->
  +    parse_options(Options, State#state{queue_if_disconnected = true}).
  +
   maybe_reply({reply, Reply, State}) ->
       Request = State#state.active,
       NewRequest = send_caller(Reply, Request),
  
positive.code: %% @doc Perform a map/reduce job across the cluster.
  %%      See the map/reduce documentation for explanation of behavior.
  mapred(Pid, Inputs, Query, Timeout) ->
      {ok, ReqId} = mapred_stream(Pid, Inputs, Query, self(), Timeout),
      wait_for_mapred(ReqId, Timeout).
  
  %% @spec mapred_stream(Pid :: pid(),
  %%                     Inputs :: list(),
  
negative.code:                  ?assertEqual({error,<<"{'query',{\"Query takes a list of step tuples\",undefined}}">>},
                                Res)
               end)}
  
       ].
  
  -endif.
  