anchor.diff:                      ok
               end
       end;
  -clean_mailbox(_) ->
  +clean_mailbox(_, Count) when Count > 0 ->
       ok.
   
   
  
positive.code: % on the ibrowse_req_id format. This just drops all
  % 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
          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),
                      ok
  
negative.code:         Status when Status == init; Status == ended ->
              receive
                  {ibrowse_async_response, ReqId, _} ->
                      clean_mailbox({ibrowse_req_id, ReqId}, Count - 1);
                  {ibrowse_async_response_end, ReqId} ->
                      put(?STREAM_STATUS, ended),
                      ok
  