anchor.diff:                  types = [],
                   columns = [],
                   rows = [],
  -                results = []}.
  -
  -add_result(State = #state{queue = Q, results = Results}, Notice, Result) ->
  +                results = [],
  +                batch = []}.
  +
  +add_result(State, Notice, Result) ->
  +    #state{queue = Q, results = Results, batch = Batch} = State,
       Results2 = case queue:get(Q) of
                      {{incremental, From, Ref}, _} ->
                          From ! {self(), Ref, Notice},
  
positive.code:                  bind ->
                       finish(State, ok);
                   execute_batch ->
                       State
               end,
      {noreply, State2};
  
  
negative.code:                    _ ->
                         [Result | Results]
                 end,
      Batch2 = case Batch of
                   [] -> [];
                   _ -> tl(Batch)
               end,
      State#state{types = [],
                  columns = [],
                  rows = [],
                  results = Results2,
                  batch = Batch2}.
  
  add_row(State = #state{queue = Q, rows = Rows}, Data) ->
      Rows2 = case queue:get(Q) of
  