anchor.diff:                  rows = [],
                   results = []}.
   
  -add_result(State = #state{results = Results}, Notice, Result) ->
  +add_result(State = #state{queue = Q, results = Results}, Notice, Result) ->
  +    Results2 = case queue:get(Q) of
  +                   {{incremental, From, Ref}, _} ->
  +                       From ! {Ref, Notice},
  +                       Results;
  +                   _ ->
  +                       [Result | Results]
  +               end,
       State#state{types = [],
                   columns = [],
                   rows = [],
  -                results = [Result | Results]}.
  -
  -add_row(State = #state{rows = Rows}, Data) ->
  -    State#state{rows = [Data | Rows]}.
  +                results = Results2}.
  +
  +add_row(State = #state{queue = Q, rows = Rows}, Data) ->
  +    Rows2 = case queue:get(Q) of
  +                {{incremental, From, Ref}, _} ->
  +                    From ! {Ref, {data, Data}},
  +                    Rows;
  +                _ ->
  +                    [Data | Rows]
  +            end,
  +    State#state{rows = Rows2}.
   
   notify(State = #state{queue = Q}, Notice) ->
  -    %% TODO handle 'incremental' request
  +    case queue:get(Q) of
  +        {{incremental, From, Ref}, _} ->
  +            From ! {Ref, Notice};
  +        _ ->
  +            ignore
  +    end,
       State.
   
  -notify_async(#state{async = Pid}, Msg) ->
  +notify_async(State = #state{async = Pid}, Msg) ->
       case is_pid(Pid) of
           true  -> Pid ! {pgsql, self(), Msg};
           false -> false
  -    end.
  +    end,
  +    State.
   
   command_tag(#state{queue = Q}) ->
       {_, Req} = queue:get(Q),
  
positive.code: 
  %% NoticeResponse
  on_message({$N, Data}, State) ->
      notify_async(State, {notice, pgsql_wire:decode_error(Data)}),
      {noreply, State};
  
  %% ParameterStatus
  on_message({$S, Data}, State) ->
  
negative.code:     case queue:get(Q) of
          {{cast, From, Ref}, _} ->
              From ! {Ref, Result};
          {{incremental, From, Ref}, _} ->
              From ! {Ref, Notice};
          {{call, From}, _} ->
              gen_server:reply(From, Result)
      end,
  