anchor.diff:                        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).
   
  
positive.code:     end,
      receive
          {notify_watcher, _} -> ok;
          _ -> ok
      after Wait -> ok
      end,
      handle_pool_info_streaming(Id, Req, UserPassword, HTTPRes,
  
negative.code:     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
  