anchor.diff:          [spawn(
              fun() ->
                      Loop = fun(F) ->
  -                            {ok, Result} = gcounter_on_cseq:read_state(Key),
  -                            UnitTestPid ! {testreturn, Id, Result},
  -                            F(F)
  +                            receive
  +                                {reader_done} ->
  +                                    UnitTestPid ! {reader_terminated}
  +                            after 0 ->
  +                                {ok, Result} = gcounter_on_cseq:read_state(Key),
  +                                UnitTestPid ! {testreturn, Id, Result},
  +                                F(F)
  +                            end
                             end,
                      Loop(Loop)
              end)
  
positive.code:     end || Nth <- lists:seq(1, NumberOfWriter)],
      ok.
  
  -spec spawn_monotonic_reader(pid(), fun(() -> crdt:crdt()), fun((term(), term()) -> boolean())) -> pid().
  spawn_monotonic_reader(UnitTestPid, ReadFun, LTEQCompareFun) ->
      spawn_monotonic_reader(UnitTestPid, ReadFun, LTEQCompareFun, none).
  
negative.code:                end,
      _ = spawn_writers(UnitTestPid, Parallel, Count, WriteFun),
      wait_writers_completion(Parallel),
      stop_readers(Reader),
  
      receive {compare_failed, A, B} ->
          ?ct_fail("~n~w ~nis not smaller or equals than ~n~w", [A, B])
      after 100 ->
  