anchor.diff:  % messages for the given ReqId on the floor since we're
   % no longer in the HTTP request.
   clean_mailbox({ibrowse_req_id, ReqId}) ->
  -    case get(STREAM_STATUS) of
  +    case get(?STREAM_STATUS) of
           streaming ->
               ibrowse:stream_next(ReqId),
               receive
                   {ibrowse_async_response, ReqId, _} ->
                       clean_mailbox({ibrowse_req_id, ReqId});
                   {ibrowse_async_response_end, ReqId} ->
  -                    put(STREAM_STATUS, ended),
  +                    put(?STREAM_STATUS, ended),
                       ok
               end;
  -        _ ->
  +        Status when Status == init; Status == ended ->
               receive
                   {ibrowse_async_response, ReqId, _} ->
                       clean_mailbox({ibrowse_req_id, ReqId});
                   {ibrowse_async_response_end, ReqId} ->
  -                    put(STREAM_STATUS, ended),
  +                    put(?STREAM_STATUS, ended),
                       ok
               end
       end;
  
positive.code:         ibrowse:stream_next(ReqId),
          {Data, fun() -> stream_data_self(HttpDb, Params, Worker, ReqId, Cb) end};
      {Data, ibrowse_async_response_end} ->
          put(STREAM_STATUS, ended),
          {Data, fun() -> throw({maybe_retry_req, more_data_expected}) end}
      end.
  
  
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),
  