anchor.diff:      worker_count,
       workers,
       reply_count = 0,
  +    reply_error_count = 0,
       r,
       revs,
       latest,
  
positive.code:     end).
  
  
  check_not_found_replies_are_removed_when_doc_found() ->
      ?_test(begin
          Replies = replies_to_dict([foo1(), bar1(), fooNF()]),
  
negative.code: 
  handle_message({rexi_DOWN, _, {_,NodeRef},_}, _Worker, #state{workers=Workers}=State) ->
      NewState = State#state{
          workers = lists:keydelete(NodeRef, #shard.node, Workers),
          reply_error_count = State#state.reply_error_count + 1
      },
      handle_message({ok, []}, nil, NewState);
  
  handle_message({rexi_EXIT, _}, Worker, #state{workers=Workers}=State) ->
      NewState = State#state{
          workers = lists:delete(Worker, Workers),
          reply_error_count = State#state.reply_error_count + 1
      },
      handle_message({ok, []}, nil, NewState);
  
  