anchor.diff:          resource = "_changes",
           qs = QS,
           conn = Pid,
  -        options = [{stream_to, {self(), once}}, {response_format, binary}],
  +        options = [{stream_to, {self(), once}}] ++
  +                lists:keydelete(inactivity_timeout, 1, Source#http_db.options),
           headers = Source#http_db.headers -- [{"Accept-Encoding", "gzip"}]
       },
       {ibrowse_req_id, ReqId} = couch_rep_httpc:request(Req),
  +    Args = [Parent, Req, Since, PostProps],
   
       receive
       {ibrowse_async_headers, ReqId, "200", _} ->
  
positive.code:     ibrowse:stream_next(S#state.reqid);
  maybe_stream_next(_) ->
      timer:cancel(get(timeout)).
  
  start_http_request(RawUrl) ->
      Url = ibrowse_lib:parse_url(RawUrl),
      {ok, Pid} = ibrowse:spawn_link_worker_process(Url#url.host, Url#url.port),
      Opts = [
          {stream_to, {self(), once}},
          {inactivity_timeout, 31000},
          {response_format, binary}
      ],
      {ibrowse_req_id, Id} =
          ibrowse:send_req_direct(Pid, RawUrl, [], get, [], Opts, infinity),
      {Pid, Id}.
  
negative.code: stop(Server) ->
      gen_server:call(Server, stop).
  
  init([Parent, #http_db{}=Source, Since, PostProps]) ->
      process_flag(trap_exit, true),
      Feed = case couch_util:get_value(<<"continuous">>, PostProps, false) of
      false ->
  