anchor.diff:      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) ->
  +    handle_streaming(F, Req, HTTPRes, LastRes).
  +
  +handle_streaming(F, Req, HTTPRes, LastRes) ->
       Res = F(stable),
       case Res =:= LastRes of
           true -> ok;
  
positive.code:         _ ->
              error_logger:info_msg("menelaus_web streaming socket closed~n"),
              exit(normal)
      after Wait -> ok
      end,
      handle_streaming(F, Req, HTTPRes, Res, Wait).
  
  all_accessible_buckets(PoolId, Req) ->
      Pool = find_pool_by_id(PoolId),
  
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
  