anchor.diff:      fetch_data(Worker1, Ref1, notify_fun(), on_complete_fun(self())),
   
       %% then
  -    ?assertReceivedMatch({on_complete, {error,{other,{send_error,normal}}}}, ?TIMEOUT).
  +    ?assertReceivedMatch({on_complete, {error,{storage,_}}}, ?TIMEOUT).
   
   error_write_fun_test(Config) ->
       %% test with write_fun callback returning an error
  
positive.code:     fetch_data(Worker1, Ref1, notify_fun(), on_complete_fun(self())),
  
      %% then
      ?assertReceivedMatch({on_complete, {error,{other,{send_error,normal}}}}, ?TIMEOUT).
  
  bad_formatted_request_test(Config) ->
      %% test calling fetch with bad _request
  
negative.code:     fetch_data(Worker1, Ref1, notify_fun(), on_complete_fun(self())),
  
      %% then
      ?assertReceivedMatch({on_complete, {error,{storage,_}}}, ?TIMEOUT).
  
  error_read_fun_test(Config) ->
      %% test with read_fun callback returning an error
  