anchor.diff:      case Res =:= LastRes of
           true -> ok;
           false ->
  +            error_logger:info_msg("menelaus_web streaming: ~p~n",
  +                                  [Res]),
               HTTPRes:write_chunk(mochijson2:encode(Res)),
               %% TODO: resolve why mochiweb doesn't support zero chunk... this
               %%       indicates the end of a response for now
  
positive.code:     end,
      receive
          {notify_watcher, _} -> ok;
          _ -> ok
      after Wait -> ok
      end,
      handle_bucket_info_streaming(PoolId, Id, Req, UserPassword, HTTPRes,
  
negative.code:                       chunked}),
      %% Register to get config state change messages.
      menelaus_event:register_watcher(self()),
      Sock = Req:get(socket),
      inet:setopts(Sock, [{active, true}]),
      handle_pool_info_streaming(Id, Req, UserPassword, HTTPRes,
                                 undefined, 3000).
  
  