anchor.diff:                rdht_tx_write ->
                     rdht_tx_write:work_phase(self(), NewReqId, Entry)
             end,
  -          {NewReqId, Entry}
  +          NewReqId
         end || Entry <- ReqList ].
   
   %% @doc Collect replies from the quorum DHT operations.
  --spec collect_replies(tx_tlog:tlog(), [{req_id(), request_on_key()}]) -> tx_tlog:tlog().
  -collect_replies(TLog, [_|_] = ReqIdsReqList) ->
  -    ?TRACE("rdht_tx:collect_replies(~p, ~p)~n", [TLog, ReqIdsReqList]),
  -    % TODO: receive only matching replies?!
  -    % (as a result we would not need to parse through the reqlist over and over again!)
  -    {_, ReqId, RdhtTlogEntry} = receive_answer(),
  -    case lists:keytake(ReqId, 1, ReqIdsReqList) of
  -        {value, _ReqIdReq, NewReqIdsReqList} ->
  -            %% add TLog entry, as it is guaranteed a necessary entry
  -            NewTLog = [RdhtTlogEntry | TLog],
  -            collect_replies(NewTLog, NewReqIdsReqList);
  -        false ->
  -            %% Drop outdated result...
  -            collect_replies(TLog, ReqIdsReqList)
  -    end;
  -collect_replies(TLog, []) -> tx_tlog:sort_by_key(TLog).
  +-spec collect_replies(tx_tlog:tlog(), [req_id()]) -> tx_tlog:tlog().
  +collect_replies(TLog, [ReqId | RestReqIds] = _ReqIdsList) ->
  +    ?TRACE("rdht_tx:collect_replies(~p, ~p)~n", [TLog, _ReqIdsList]),
  +    % receive only matching replies
  +    RdhtTlogEntry = receive_answer(ReqId),
  +    NewTLog = [RdhtTlogEntry | TLog],
  +    collect_replies(NewTLog, RestReqIds);
  +collect_replies(TLog, []) ->
  +    %% Drop outdated results...
  +    receive_old_answers(),
  +    tx_tlog:sort_by_key(TLog).
   
   %% @doc Merge TLog entries, if same key. Check for version mismatch,
   %%      take over values.
  
positive.code:     end.
  
  %% @doc Trigger operations for the DHT.
  -spec initiate_rdht_ops([request_on_key()]) -> [{req_id(), request_on_key()}].
  initiate_rdht_ops(ReqList) ->
      ?TRACE("rdht_tx:initiate_rdht_ops(~p)~n", [ReqList]),
      %% @todo should choose a dht_node in the local VM at random or even
  
negative.code: 
      %% perform RDHT operations to collect missing TLog entries
      %% rdht requests for independent keys are processed in parallel.
      ReqIds = initiate_rdht_ops(ReqListonRDHT),
  
      RTLog = collect_replies(tx_tlog:empty(), ReqIds),
  
      %% merge TLogs (insert fail, abort, when version mismatch
      %% in reads for same key is detected)
  