anchor.diff:  handle_pool_info_streaming(Id, Req) ->
       UserPassword = menelaus_auth:extract_auth(Req),
       F = fun(InfoLevel) -> build_pool_info(Id, UserPassword, InfoLevel) end,
  -    handle_streaming(F, Req, undefined, 3000).
  -
  -handle_streaming(F, Req, LastRes, Wait) ->
  +    handle_streaming(F, Req, undefined).
  +
  +handle_streaming(F, Req, LastRes) ->
       HTTPRes = Req:ok({"application/json; charset=utf-8",
                         server_header(),
                         chunked}),
  
positive.code:     menelaus_event:register_watcher(self()),
      Sock = Req:get(socket),
      inet:setopts(Sock, [{active, true}]),
      handle_streaming(F, Req, HTTPRes, LastRes, Wait).
  
  handle_streaming(F, Req, HTTPRes, LastRes, Wait) ->
      Res = F(stable),
      case Res =:= LastRes of
          true -> ok;
  
negative.code: 
  handle_bucket_info_streaming(PoolId, Id, Req, Pool, _Bucket) ->
      F = fun(InfoLevel) -> build_bucket_info(PoolId, Id, Pool, InfoLevel) end,
      handle_streaming(F, Req, undefined).
  
  handle_bucket_delete(PoolId, BucketId, Req) ->
      case mc_bucket:bucket_delete(PoolId, BucketId) of
  