anchor.diff:          ibrowse:stream_next(ReqId),
           {Data, fun() -> stream_data_self(HttpDb, Params, Worker, ReqId, Cb) end};
       {Data, ibrowse_async_response_end} ->
  -        put(STREAM_STATUS, ended),
  +        put(?STREAM_STATUS, ended),
           {Data, fun() -> throw({maybe_retry_req, more_data_expected}) end}
       end.
   
  
positive.code: 
  
  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, [])]),
  
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),
  