anchor.diff:      receive
   	die ->
   	    nil;
  -	{done, NumReceived} ->
  +	{mappers, done, NumReceived} ->
   	    Parent ! {self (), Dict};
   	Keys  ->
   	    reducer(Parent, add_keys(Dict, Keys), NumReceived + 1)
  
positive.code: cluster_runmany(Fun, Fuse, TaskList, Nodes, Running, Results) when length(Running) > 0 ->
      receive
  	{Pid, Num, Result} ->
  	    % throw out the normal exit message
  	    receive {'DOWN', _, _, Pid, normal} ->
  		    nil;
  		    {'DOWN', _, _, Pid, noproc}->
  		    nil
  	    end,
  	    {Running2, FinishedNode, _} = delete_running(Pid, Running, []),
  
negative.code:     Fun2 = fun (L) -> lists:foldl(Fun, InitAcc, L) end,
      runmany(Fun2, Fuse, List, Malt).
  
  % @doc Similiar to foreach in module
  % <a href="http://www.erlang.org/doc/man/lists.html">lists</a>
  % except it makes no guarantee about the order it processes list elements.
  % @spec (Fun, List) -> void()
  foreach(Fun, List) ->
      foreach(Fun, List, 1).
  
  % @doc Similiar to foreach in module
  % <a href="http://www.erlang.org/doc/man/lists.html">lists</a>
  % except it makes no guarantee about the order it processes list elements.
  % @spec (Fun, List, Malt) -> void()
  foreach(Fun, List, Malt) ->
      runmany(fun (L) ->
  