anchor.diff:              StreamDataFun = fun() ->
                   stream_data_self(HttpDb, Params, Worker, ReqId, Callback)
               end,
  -            put(?STREAM_STATUS, streaming),
  +            put(?STREAM_STATUS, {streaming, Worker}),
               ibrowse:stream_next(ReqId),
               try
                   Ret = Callback(Ok, Headers, StreamDataFun),
  
positive.code:     ok;
  clean_mailbox({ibrowse_req_id, ReqId}, Count) when Count > 0 ->
      case get(?STREAM_STATUS) of
          streaming ->
              ibrowse:stream_next(ReqId),
              receive
                  {ibrowse_async_response, ReqId, _} ->
  
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 ->
  