anchor.diff:                                      },
       op_insert_gc(Key,DownstreamOp1, OpsCache, SnapshotCache),
       io:format("after making the first write: Opscache= ~p~n SnapCache=~p", [orddict:to_list(OpsCache), orddict:to_list(SnapshotCache)]),
  -    {ok, Res1} = internal_read(ignore, Key, Type, vectorclock:from_list([{DC1,16}]),ignore,  OpsCache, SnapshotCache),
  +    {ok, Res1} = internal_read(ignore, Key, Type, vectorclock:from_list([{DC1,16}]), ignore, OpsCache, SnapshotCache),
       ?assertEqual(1, Type:value(Res1)),
       io:format("after making the first read: Opscache= ~p~n SnapCache=~p", [orddict:to_list(OpsCache), orddict:to_list(SnapshotCache)]),
       %% Insert second increment
  
positive.code: 
  %% @doc This function takes care of reading. It is implemented here for not blocking the
  %% vnode when the write function calls it. That is done for garbage collection.
  -spec internal_read(pid() | ignore, key(), type(), snapshot_time(), txid() | ignore, ets:tid() , ets:tid() ) -> {ok, term()} | {error, no_snapshot}.
  internal_read(Sender, Key, Type, SnapshotTime, TxId, OpsCache, SnapshotCache) ->
      case ets:lookup(SnapshotCache, Key) of
          [] ->
              SnapshotDict = orddict:new(),
              LatestSnapshot = clocksi_materializer:new(Type),
              SnapshotCommitTime = ignore;
          [{_, SnapshotDict}] ->
              case get_latest_snapshot(SnapshotDict, SnapshotTime) of
                  {ok, no_snapshot} ->
                      LatestSnapshot = clocksi_materializer:new(Type),
                      SnapshotCommitTime = ignore;
                  {ok, {SCT, LS}}->
                      {SnapshotCommitTime, LatestSnapshot} = {SCT, LS}
              end
      end,
      case ets:lookup(OpsCache, Key) of
  
negative.code: 
  handle_command({read, Key, Type, SnapshotTime, TxId}, Sender,
                 State = #state{ops_cache=OpsCache, snapshot_cache=SnapshotCache}) ->
      %% @todo Why is the return value ignored??
      _ = internal_read(Sender, Key, Type, SnapshotTime, TxId, OpsCache, SnapshotCache),
      {noreply, State};
  
  handle_command({update, Key, DownstreamOp}, _Sender,
  