anchor.diff:                              [["TestWrite"]]]),
   
       remove_slow_link(Link),
  -    receive {message_received} -> ok end,
  +    wait_until_notification(1),
   
       %% all replicas should have received the written value
       ?equals(prbr_values(), [[["TestWrite"]],
  
positive.code:     TestPid = self(),
      Key = "1234",
  
      [get_notified_by_message(self(), 1, kv_db, I, dht_node, write) || I <- lists:seq(1,2)],
      _LinkA = slow_link(1, kv_db, 3, dht_node, write),
      _LinkB = slow_link(1, kv_db, 4, dht_node, write),
  
      % start write A which will not finish since it only gets two write ack.
      spawn(fun() ->
  
negative.code:     %% Do a read over replica 1, 2, 3
      %% It should be an inconsistent read and currently diverging replica 1
      %% should be repaired,
      get_notified_by_message(4, 4, write),
      LinkD = slow_link(4, 4),
      {ok, _} = read_via_node(4, Key, element(1, filter_list_append())),
      remove_slow_link(LinkD),
      wait_until_notification(1),
  
      ct:pal("PRBR state after inconsistent read: ~n~p", [prbr_data()]),
      PrbrData2 = prbr_values(),
  