anchor.diff:              end
       end.
   
  -%% TODO: upgrade to newer erlang version so can use dict type spec
  -%%-spec finish_op_load(dict:dict(key(), clocksi_payload())) -> dict:dict(key(), [{non_neg_integer(), clocksi_payload()}]).
  --spec finish_op_load(dict:dict()) -> dict:dict().
  +-spec finish_op_load(dict:dict(key(), clocksi_payload())) -> dict:dict(key(), [{non_neg_integer(), clocksi_payload()}]).
   finish_op_load(CommittedOpsDict) ->
       dict:fold(fun(Key, CommittedOps, Acc) ->
           dict:store(Key, reverse_and_add_op_id(CommittedOps, 0, []), Acc)
  
positive.code:     end.
  
  %% @doc This method successively calls disk_log:chunk so all the log is read.
  %% With each valid chunk, filter_terms_for_key is called.
  %% TODO: upgrade to newer erlang version so can use dict type spec
  %% -spec get_ops_from_log(log_id(), key(), disk_log:continuation() | start, snapshot_time(),
  %%                dict:dict(txid(), [any_log_payload()]), dict:dict(key(), [{non_neg_integer(), #clocksi_payload()}]), load_all | load_per_chunk) ->
  %%                    {disk_log:continuation(), dict:dict(txid(), [any_log_payload()]), dict:dict(key(), [{non_neg_integer(), #clocksi_payload()}])}
  %%                    | {error, reason()} | {eof, dict:dict(key(), [{non_neg_integer(), #clocksi_payload()}])}.
  -spec get_ops_from_log(log_id(), key(), disk_log:continuation() | start, snapshot_time(), dict:dict(), dict:dict(), load_all | load_per_chunk) ->
                    {disk_log:continuation(), dict:dict(), dict:dict()}
                    | {error, reason()} | {eof, dict:dict()}.
  get_ops_from_log(Log, Key, Continuation, MinSnapshotTime, Ops, CommittedOpsDict, LoadAll) ->
      case disk_log:chunk(Log, Continuation) of
          {error, Reason} ->
  
negative.code:             filter_terms_for_key(Terms, Key, MinSnapshotTime, Ops, CommittedOpsDict)
      end.
  
  -spec handle_update(txid(), key(), update_ops_dict(), #update_log_payload{}) -> update_ops_dict().
  handle_update(TxId, Key, Ops, OpPayload = #update_log_payload{
      key = UpdatedKey
  }) ->
  