anchor.diff:              {ok, {WaitingCount - 1, DocCount, W, NewGrpDocs, DocReplyDict}};
           {stop, W, FinalReplies} ->
               {stop, {ok, FinalReplies}}
  -        end
  +        end;
  +    _ ->
  +        {ok, {WaitingCount - 1, DocCount, W, NewGrpDocs, DocReplyDict}}
       end;
   handle_message({missing_stub, Stub}, _, _) ->
       throw({missing_stub, Stub});
  
positive.code:     handle_message({ok, [X || _D <- Docs]}, Worker, Acc0);
  handle_message({bad_request, Msg}, _, _) ->
      throw({bad_request, Msg}).
  
  force_reply(Doc, [], {_, W, Acc}) ->
      {error, W, [{Doc, {error, internal_server_error}} | Acc]};
  
negative.code:     % icky, if replicated_changes only errors show up in result
      append_update_replies(Rest, [], dict:append(Doc, noreply, Dict0));
  append_update_replies([Doc|Rest1], [Reply|Rest2], Dict0) ->
      append_update_replies(Rest1, Rest2, dict:append(Doc, Reply, Dict0)).
  
  skip_message({0, _, W, _, DocReplyDict}) ->
  