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