anchor.diff:  %%                                   {stop, Reason, State}
   %% @end
   %%--------------------------------------------------------------------
  -handle_info(Info, State) ->
  -    io:format("in handle info for riak_kv_qry~n- ~p~n", [Info]),
  +handle_info({QId, done},
  +            State = #state{qid = QId,
  +                           status = QStatus})
  +  when QStatus =/= complete ->
  +    {noreply, State#state{status = complete}};
  +
  +handle_info({QId, {results, [Chunk]}},
  +            State = #state{qid = QId,
  +                           status = QStatus,
  +                           result = Accumulated})
  +  when QStatus =:= void; QStatus =:= accumulating ->
  +    {noreply, State#state{status = accumulating,
  +                          result = [Chunk | Accumulated]}};
  +
  +%% what if some late chunks arrive?
  +handle_info({QId, {results, _}},
  +            State = #state{qid = QId,
  +                           status = complete}) ->
  +    lager:warn("Discarding late chunk on qid ~p", [QId]),
  +    {noreply, State};
  +
  +%% other error conditions
  +handle_info({QId1, _}, State = #state{qid = QId2}) ->
  +    lager:warn("Bad query id ~p (expected ~p)", [QId1, QId2]),
       {noreply, State}.
  +
   
   %%--------------------------------------------------------------------
   %% @private
  
positive.code: %% @end
  %%--------------------------------------------------------------------
  handle_call(Request, _From, State) ->
      {Reply, SEs, NewState} = handle_req(Request, State),
      ok = handle_side_effects(SEs),
      {reply, Reply, NewState}.
  
  %%--------------------------------------------------------------------
  %% @private
  
negative.code: 
  %% Developer API
  -export([
           execute/2,
           fetch/2
          ]).
  
  %% gen_server callbacks
  -export([
  