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_bucket_info_streaming(PoolId, 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:     end,
      receive
          {notify_watcher, _} -> ok;
          _ ->
              error_logger:info_msg("menelaus_web streaming socket closed~n"),
              exit(normal)
      after Wait -> ok
      end,
      handle_bucket_info_streaming(PoolId, Id, Req, UserPassword, HTTPRes,
  