anchor.diff:  on_message(Error = {error, _}, State) ->
       State2 = case command_tag(State) of
                    C when C == squery; C == equery ->
  -                     State#state{results = [Error | State#state.results]};
  +                     add_result(State, Error);
                    _ ->
                        sync_required(reply(State, Error))
                end,
  
positive.code:                  execute ->
                       reply(State, Result);
                   C when C == squery; C == equery ->
                       State#state{columns = [],
                                   rows = [],
                                   results = [Result | State#state.results]}
               end,
      {noreply, State2};
  
  
negative.code:                  execute ->
                       reply(State, {ok, [], []});
                   C when C == squery; C == equery ->
                       add_result(State, {ok, [], []})
               end,
      {noreply, State2};
  
  