anchor.diff:      stats,
       enum_pid,
       docs_buffer = [],
  -    listeners = []
  +    listeners = [],
  +    done = false
   }).
   
   
  
positive.code:     },
      
      {ok, State}.
  
  handle_call(get_result, From, #state{listeners=L} = State) ->
      {noreply, State#state{listeners=[From|L]}};
  
  
negative.code: 
  handle_call({fin, {LastSeq, RevsCount}}, {Pid,_}, #state{enum_pid=Pid} = State) ->
      ets:update_counter(State#state.stats, total_revs, RevsCount),
      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]),
  