anchor.diff:                         Fun(Stat)
                  end || Stat <- RStats]}.
   
  -handle_info(log_state, State) ->
  -    case State#state.bucket of
  -        undefined ->
  -            ok;
  -        _ ->
  -            ?log_info("rebalance observer state:~n~p", [State])
  -    end,
  -    {noreply, State};
  -handle_info(_Msg, State) ->
  +handle_info(Msg, State) ->
  +    ?log_error("Got unexpected message: ~p", [Msg]),
       {noreply, State}.
   
   terminate(_Reason, _State) ->
  
positive.code:             ?log_error("Weird vbucket move start for move not in pending moves: ~p", [Ev]),
              {noreply, State};
          NewState ->
              {noreply, NewState}
      end.
  
  
negative.code:                                              gen_server:cast(Self, {note, Fun, Event})
                                       end
                               end, []),
  
      proc_lib:spawn_link(erlang, apply, [fun docs_left_updater_init/1, [Self]]),
  
  