anchor.diff:      HTTPRes = Req:ok({"application/json; charset=utf-8",
                         server_header(),
                         chunked}),
  +    %% Register to get config state change messages.
  +    menelaus_event:register_watcher(self()),
       handle_bucket_info_streaming(PoolId, Id, Req, UserPassword, HTTPRes,
                                    undefined, 3000).
   
  
positive.code:             %%       indicates the end of a response for now
              HTTPRes:write_chunk("\n\n\n\n")
      end,
      %% Register to get config state change messages.
      menelaus_event:register_watcher(self()),
      receive
          {notify_watcher, _} -> ok;
          _ -> ok
  
negative.code:             %%       indicates the end of a response for now
              HTTPRes:write_chunk("\n\n\n\n")
      end,
      receive
          {notify_watcher, _} -> ok;
          _ -> ok
  