anchor.diff:      handle_streaming(F, Req, undefined).
   
   handle_streaming(F, Req, LastRes) ->
  -    ?log_debug("Starting streaming for ~s path ~s",
  -               [menelaus_util:remote_addr_and_port(Req), Req:get(raw_path)]),
       HTTPRes = Req:ok({"application/json; charset=utf-8",
                         server_header(),
                         chunked}),
  
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:             consume_watcher_notifies(),
              ok;
          _ ->
              exit(normal)
      after 25000 ->
              ok
  