anchor.diff:  
   %% @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, []) -> tx_tlog:sort_by_key(TLog);
  -collect_replies(TLog, ReqIdsReqList) ->
  +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} ->
  
positive.code:         false ->
              %% Drop outdated result...
              collect_replies(TLog, ReqIdsReqList)
      end.
  
  %% @doc Merge TLog entries, if same key. Check for version mismatch,
  %%      take over values.
  
negative.code:              receive_answer()
            );
          ?SCALARIS_RECV(
             {_Op, _RdhtId, _RdhtTlog} = Msg, %% ->
               Msg
            )
      end.
  
  