anchor.diff:      menelaus_event:register_watcher(self()),
       Sock = Req:get(socket),
       inet:setopts(Sock, [{active, true}]),
  -    handle_pool_info_streaming(Id, Req, UserPassword, HTTPRes,
  -                               undefined, 3000).
  -
  -handle_pool_info_streaming(Id, Req, UserPassword, HTTPRes,
  -                           LastRes, Wait) ->
  -    Res = build_pool_info(Id, UserPassword),
  +    handle_streaming(F, Req, HTTPRes, LastRes, Wait).
  +
  +handle_streaming(F, Req, HTTPRes, LastRes, Wait) ->
  +    Res = F(),
       case Res =:= LastRes of
           true -> ok;
           false ->
  
positive.code: 
  handle_pool_info_streaming(Id, Req) ->
      UserPassword = menelaus_auth:extract_auth(Req),
      HTTPRes = Req:ok({"application/json; charset=utf-8",
                        server_header(),
                        chunked}),
  
negative.code:             exit(normal)
      after Wait -> ok
      end,
      handle_streaming(F, Req, HTTPRes, Res, Wait).
  
  handle_bucket_list(Id, Req) ->
  	MyPool = find_pool_by_id(Id),
  