anchor.diff:                        "menelaus_web streaming socket closed by client"),
               exit(normal)
       after 25000 ->
  -        ok
  +            ok
       end,
       handle_streaming(F, Req, HTTPRes, Res).
   
  
positive.code:          parse_validate_bucket_fast_warmup_settings/1]).
  
  -export([ns_log_cat/1, ns_log_code_string/1, alert_key/1]).
  
  -import(menelaus_util,
          [server_header/0,
  
negative.code:                 HTTPRes:write_chunk(""),
                  exit(normal)
          end,
      erlang:hibernate(?MODULE, handle_streaming_wakeup, [F, Req, HTTPRes, Res]).
  
  handle_streaming_wakeup(F, Req, HTTPRes, Res) ->
      receive
          {notify_watcher, _} ->
              timer:sleep(50),
  