anchor.diff:      end,
       State#state{queue = QueueN}.
   
  -reduce_done_check(#state{done = false} = State) ->
  +reduce_done_check(#state{map_done = false} = State) ->
       {ok, State};
  -reduce_done_check(#state{done = true,
  +reduce_done_check(#state{map_done = true,
                            queue = Queue} = State) ->
       ReduceSize = cloudi_queue:size(Queue),
       if
  
positive.code:             NewIndex = Index + Step * Iterations,
              {ok, SendArgs,
               State#state{index = NewIndex,
                           done = (NewIndex > IndexEnd)}};
          {error, _} = Error ->
              Error
      end.
  
negative.code:                       task_size = TaskSize,
                        queue = Queue}, Dispatcher)}.
  
  cloudi_service_map_reduce_send(#state{map_done = true} = State, _) ->
      {done, State};
  cloudi_service_map_reduce_send(#state{destination = Name,
                                        index = Index,
  