anchor.diff:  
   handle_call({fin, {LastSeq, RevsCount}}, {Pid,_}, #state{enum_pid=Pid} = State) ->
       ets:update_counter(State#state.stats, total_revs, RevsCount),
  -    {stop, normal, ok, State#state{current_seq=LastSeq}}.
  +    case State#state.listeners of
  +    [] ->
  +        % still waiting for the first listener to sen a request
  +        {noreply, State#state{current_seq=LastSeq}};
  +    _ ->
  +        {stop, normal, ok, State#state{current_seq=LastSeq}}
  +    end.
   
   handle_cast({increment_update_seq, Seq}, State) ->
       couch_task_status:update("Processed source update #~p", [Seq]),
  
positive.code:     stats,
      enum_pid,
      docs_buffer = [],
      listeners = []
  }).
  
  
  
negative.code:     ets:delete(Stats),
      close_db(Target),
      
      [Original|Rest] = Listeners,
      gen_server:reply(Original, {ok, NewRepHistory}),
      
      %% maybe trigger another replication. If this replicator uses a local 
      %% source Db, changes to that Db since we started will not be included in 
  