anchor.diff:  stop(Server) ->
       gen_server:call(Server, stop).
   
  -init([_Parent, #http_db{}=Source, Since, PostProps] = Args) ->
  +init([Parent, #http_db{}=Source, Since, PostProps]) ->
       process_flag(trap_exit, true),
       Feed = case couch_util:get_value(<<"continuous">>, PostProps, false) of
       false ->
  
positive.code:         resource = "_changes",
          qs = QS,
          conn = Pid,
          options = [{stream_to, {self(), once}}, {response_format, binary}],
          headers = Source#http_db.headers -- [{"Accept-Encoding", "gzip"}]
      },
      {ibrowse_req_id, ReqId} = couch_rep_httpc:request(Req),
  
      receive
      {ibrowse_async_headers, ReqId, "200", _} ->
  
negative.code:     ibrowse:stream_next(S#state.reqid);
  maybe_stream_next(_) ->
      timer:cancel(get(timeout)).
  