anchor.diff:  
   
   send_req(HttpDb, Params1, Callback) ->
  +    put(STREAM_STATUS, init),
       couch_stats:increment_counter([couch_replicator, requests]),
       Params2 = ?replace(Params1, qs,
           [{K, ?b2l(iolist_to_binary(V))} || {K, V} <- get_value(qs, Params1, [])]),
  
positive.code: 
  -define(replace(L, K, V), lists:keystore(K, 1, L, {K, V})).
  -define(MAX_WAIT, 5 * 60 * 1000).
  
  
  setup(#httpdb{httpc_pool = nil, url = Url, http_connections = MaxConns} = Db) ->
  
negative.code:             StreamDataFun = fun() ->
                  stream_data_self(HttpDb, Params, Worker, ReqId, Callback)
              end,
              put(STREAM_STATUS, streaming),
              ibrowse:stream_next(ReqId),
              try
                  Ret = Callback(Ok, Headers, StreamDataFun),
  