anchor.diff:              consume_watcher_notifies(),
               ok;
           _ ->
  -            ale:debug(?MENELAUS_LOGGER,
  -                      "menelaus_web streaming socket closed by client"),
               exit(normal)
       after 25000 ->
               ok
  
positive.code:     Res =
          try streaming_inner(F, HTTPRes, LastRes)
          catch exit:normal ->
                  ale:debug(?MENELAUS_LOGGER, "closing streaming socket~n"),
                  HTTPRes:write_chunk(""),
                  exit(normal)
          end,
  
negative.code:     handle_streaming(F, Req, undefined).
  
  handle_streaming(F, Req, LastRes) ->
      HTTPRes = Req:ok({"application/json; charset=utf-8",
                        server_header(),
                        chunked}),
  