anchor.diff:      },
       
       {ok, State}.
  -
  +handle_call(get_result, From, #state{listeners=L,done=true} = State) ->
  +    {stop, normal, State#state{listeners=[From|L]}};
   handle_call(get_result, From, #state{listeners=L} = State) ->
       {noreply, State#state{listeners=[From|L]}};
   
  
positive.code: 
  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}}.
  
  handle_cast({increment_update_seq, Seq}, State) ->
      couch_task_status:update("Processed source update #~p", [Seq]),
  
negative.code:     stats,
      enum_pid,
      docs_buffer = [],
      listeners = [],
      done = false
  }).
  
  
  