anchor.diff:  handle_pool_info_streaming(Id, Req) ->
       %% TODO: this shouldn't be timer driven, but rather should register a callback based on some state change in the Erlang OS
       HTTPRes = Req:ok({"application/json; charset=utf-8",
  -                      [{"Server", "NorthScale menelaus %TODO gitversion%"}],
  +                      server_header(),
                         chunked}),
       UserPassword = extract_basic_auth(Req),
       Res = build_pool_info(Id, UserPassword),
  
positive.code:         "on" -> tgen:traffic_start()
      end,
      Req:respond({200, [], []}).
  
negative.code:             end,
      Res = {struct, List2},
      reply_json(Req, Res).
  
  handle_bucket_info_streaming(_PoolId, Id, Req) ->
      %% TODO: this shouldn't be timer driven, but rather should register a callback based on some state change in the Erlang OS
      HTTPRes = Req:ok({"application/json; charset=utf-8",
                        server_header(),
                        chunked}),
      UserPassword = extract_basic_auth(Req),
      Res = build_pool_info(Id, UserPassword),
      HTTPRes:write_chunk(mochijson2:encode(Res)),
      %% TODO: resolve why mochiweb doesn't support zero chunk... this
      %%       indicates the end of a response for now
      HTTPRes:write_chunk("\n\n\n\n"),
      handle_bucket_info_streaming(_PoolId, Id, Req, HTTPRes, 3000).
  
  handle_bucket_info_streaming(_PoolId, Id, Req, HTTPRes, Wait) ->
      receive
      after Wait ->
              UserPassword = extract_basic_auth(Req),
              Res = build_pool_info(Id, UserPassword),
              HTTPRes:write_chunk(mochijson2:encode(Res)),
              %% TODO: resolve why mochiweb doesn't support zero chunk... this
              %%       indicates the end of a response for now
              HTTPRes:write_chunk("\n\n\n\n")
      end,
      handle_pool_info_streaming(Id, Req, HTTPRes, 10000).
  
  %% milliseconds since 1970 Jan 1 at UTC
  java_date() ->
  