anchor.diff:      Self = self(),
       spawn_link(
         fun () ->
  -              case BucketType of
  -                  memcached ->
  -                      ok;
  -                  membase ->
  -                      ok = capi_set_view_manager:wait_until_added(NewNode, Bucket, VBucket)
  -              end,
  +              ok = capi_set_view_manager:wait_until_added(NewNode, Bucket, VBucket),
                 Self ! {update_vbucket_map, Node, VBucket, OldChain, NewChain}
         end),
   
  
positive.code: -type progress_callback() :: fun((dict()) -> any()).
  
  -record(state, {bucket::nonempty_string(),
                  bucket_type::memcached | membase,
                  disco_events_subscription::pid(),
                  initial_counts::dict(),
                  max_per_node::pos_integer(),
  
negative.code:                                             end),
      erlang:start_timer(30000, self(), log_tap_stats),
  
      {ok, #state{bucket=Bucket,
                  disco_events_subscription=Subscription,
                  initial_counts=count_moves(MoveDict),
                  max_per_node=?MAX_MOVES_PER_NODE,
  