anchor.diff:  -define(NO_MAX_RESULTS, no_max_results).
   -define(NO_PG_SORT, undefined).
   
  +
   -record(state, {
  -          name                 :: atom(),
  -          ddl                  :: undefined | #ddl_v1{},
  -          qry      = none      :: none | #riak_sql_v1{},
  -          qid      = undefined :: undefined | {node(), non_neg_integer()},
  -          sub_qrys  = []       :: [integer()],
  -          status    = void     :: void | accumulating_chunks,
  -          receiver_pid         :: pid(),
  -          result    = []       :: [{non_neg_integer(), list()}] | [{binary(), term()}]
  +          name                                :: atom(),
  +          ddl                                 :: undefined | #ddl_v1{},
  +          qry           = none                :: none | #riak_sql_v1{},
  +          qid           = undefined           :: undefined | {node(), non_neg_integer()},
  +          sub_qrys      = []                  :: [integer()],
  +          status        = void                :: void | accumulating_chunks,
  +          receiver_pid                        :: pid(),
  +          result        = []                  :: [{non_neg_integer(), list()}] | [{binary(), term()}],
  +          run_sub_qs_fn = fun run_sub_qs_fn/1 :: fun()
            }).
   
   %%%===================================================================
  
positive.code: 
  -spec handle_call(term(), {pid(), term()}, #state{}) ->
                           {reply, Reply::ok | {error, atom()} | list(), #state{}}.
  %% @private
  handle_call(Request, _, State) ->
      case handle_req(Request, State) of
          {{error, _} = Error, _SEs, NewState} ->
              {reply, Error, NewState};
          {Reply, SEs, NewState} ->
              ok = handle_side_effects(SEs),
              {reply, Reply, NewState}
      end.
  
  
  -spec handle_cast(term(), #state{}) -> {noreply, #state{}}.
  %% @private
  
negative.code: -compile(export_all).
  -include_lib("eunit/include/eunit.hrl").
  
  
  -endif.
  