anchor.diff:      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),
  -    timer:sleep(5000),
  +    ok = wait_db_updated(),
       send_local_changes_forever(Server, DbName, NewSeq).
   
   send_local_changes_once(Server, DbName, Since) ->
  
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:     {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.
  