anchor.diff:      ok;
   clean_mailbox({ibrowse_req_id, ReqId}, Count) when Count > 0 ->
       case get(?STREAM_STATUS) of
  -        streaming ->
  +        {streaming, Worker} ->
               ibrowse:stream_next(ReqId),
               receive
                   {ibrowse_async_response, ReqId, _} ->
  
positive.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),
  
negative.code:                     put(?STREAM_STATUS, ended),
                      ok
                  after 30000 ->
                      exit(Worker, {timeout, ibrowse_stream_cleanup}),
                      exit({timeout, ibrowse_stream_cleanup})
              end;
          Status when Status == init; Status == ended ->
  