anchor.diff:  % Licensed under the Apache License, Version 2.0 (the "License"); you may not
  -% use this file except in compliance with the License.  You may obtain a copy of
  +% use this file except in compliance with the License. You may obtain a copy of
   % the License at
   %
   %   http://www.apache.org/licenses/LICENSE-2.0
   %
   % Unless required by applicable law or agreed to in writing, software
   % distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  -% WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  See the
  +% WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
   % License for the specific language governing permissions and limitations under
   % the License.
   
  
positive.code:     {ibrowse_req_id, Id} = 
          ibrowse:send_req_direct(Pid, RawUrl, [], get, [], Opts, infinity),
      {Pid, Id}.
  
negative.code: decode_row(Row) ->
      ?JSON_DECODE(Row).
  
  flush_updated_messages() ->
      receive updated -> flush_updated_messages()
      after 0 -> ok
      end.
  
  local_update_notification(Self, DbName, {updated, DbName}) ->
      Self ! updated;
  local_update_notification(Self, DbName, {updated, DbName}) ->
      Self ! deleted;
  local_update_notification(_, _, _) ->
      ok.
  
  maybe_stream_next(false, Count, Id) when Count < ?MIN_BUFFER_SIZE ->
      ?LOG_DEBUG("~p reqid ~p streaming next chunk", [?MODULE, Id]),
      ibrowse:stream_next(Id);
  