anchor.diff:      Args = make_changes_args(Options),
       {ok, Acc} = Callback(start, Acc0),
       Notifiers = start_update_notifiers(DbName),
  -    {Timeout, TimeoutFun} = couch_changes:get_changes_timeout(Args, Callback),
  +    {Timeout, _} = couch_changes:get_changes_timeout(Args, Callback),
       try
           keep_sending_changes(
               DbName,
  
positive.code: find_replacement_shards(#shard{range=Range}, AllShards) ->
      % TODO make this moar betta -- we might have split or merged the partition
      [Shard || Shard <- AllShards, Shard#shard.range =:= Range].
  
negative.code:             Callback,
              get_start_seq(DbName, Args),
              Acc,
              Timeout
          )
      after
          stop_update_notifiers(Notifiers),
  