anchor.diff:          _MoreSubQueriesNotDone ->
               {noreply, State}
       end;
  +
   handle_info({{SubQId, QId}, {results, Chunk}},
               State = #state{qid      = QId,
                              qry      = Qry,
  
positive.code:                    State
             end,
      {noreply, NewS};
  handle_info({{_SubQId, QId1}, _}, State = #state{qid = QId2}) when QId1 =/= QId2 ->
      %% catches late results or errors such getting results for invalid QIds.
      lager:warning("Bad query id ~p (expected ~p)", [QId1, QId2]),
  
negative.code:             ok = handle_side_effects(SEs),
              {noreply, State2#state{ receiver_pid = ReceivePid }}
      end;
  
  handle_info({{SubQId, QId}, done},
              State = #state{qid       = QId,
                             receiver_pid = ReceiverPid,
  