anchor.diff:              end;
           {C, Ref, {complete, _Type}} ->
               {ok, lists:reverse(Rows)};
  +        {C, Ref, done} ->
  +            done;
           {'EXIT', C, _Reason} ->
               {error, closed}
       end.
  
positive.code:             throw({error, closed})
      end.
  
  receive_extended_result(C, Ref, Rows) ->
      receive
          {C, Ref, {data, Row}} ->
  
negative.code: 
  execute_batch(C, Batch) ->
      Ref = ipgsql:execute_batch(C, Batch),
      case receive_extended_results(C, Ref, []) of
          [Result] -> Result;
          Results  -> Results
      end.
  