anchor.diff:      {ibrowse_req_id, Id} = 
           ibrowse:send_req_direct(Pid, RawUrl, [], get, [], Opts, infinity),
       {Pid, Id}.
  +
  +wait_db_updated() ->
  +    receive deleted ->
  +        exit(deleted)
  +    after 0 ->
  +        receive updated ->
  +            flush_updated_messages()
  +        end
  +    end.
  
positive.code: decode_row(Row) ->
      ?JSON_DECODE(Row).
  
  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);
  
negative.code:     ok.
  
  send_local_changes_forever(Server, DbName, Since) ->
      Self = self(),
      {ok, _} = couch_db_update_notifier:start_link(
          fun(Msg) -> local_update_notification(Self, DbName, Msg) end),
      {ok, NewSeq} = send_local_changes_once(Server, DbName, Since),
      ok = wait_db_updated(),
      send_local_changes_forever(Server, DbName, NewSeq).
  
  send_local_changes_once(Server, DbName, Since) ->
  