anchor.diff:      RtransferOpts2 = [ReadFunOpt, WriteFunOpt, get_binding(Worker2) | ?DEFAULT_RTRANSFER_OPTS],
   
       %% when
  -    ?assertMatch({ok, _}, start_rtransfer(Worker1, RtransferOpts1)),
  -    ?assertMatch({ok, _}, start_rtransfer(Worker2, RtransferOpts2)),
  -
  -    Ref1 = prepare_fetch_request(
  -        Worker1, Worker2, ?TEST_FILE_UUID, ?TEST_OFFSET, DataSize
  -    ),
  -
  -    fetch_data(Worker1, Ref1, notify_fun(CounterPid), on_complete_fun(self())),
  +    prepare_rtransfer({Worker1, RtransferOpts1}, {Worker2, RtransferOpts2},
  +        ?TEST_FILE_UUID, ?TEST_OFFSET, DataSize,
  +        notify_fun(CounterPid), on_complete_fun(self())
  +    ),
   
       %% then
       ?assertReceivedMatch({on_complete, {ok, DataSize}}, ?TIMEOUT),
  
positive.code:     RtransferOpts2 = [ReadFunOpt, WriteFunOpt, get_binding(Worker2) | ?DEFAULT_RTRANSFER_OPTS],
  
      %% when
      ?assertMatch({ok, _}, start_rtransfer(Worker1, RtransferOpts1)),
      ?assertMatch({ok, _}, start_rtransfer(Worker2, RtransferOpts2)),
      Ref1 = prepare_fetch_request(
          Worker1, Worker2, ?TEST_FILE_UUID, ?TEST_OFFSET, DataSize
      ),
      fetch_data(Worker1, Ref1, notify_fun(CounterPid), on_complete_fun(self())),
  
      %% then
      ?assertReceivedMatch({on_complete, {ok, DataSize}}, ?TIMEOUT),
  
negative.code:     WriteFunOpt = make_opt_fun(write_fun, {ok, ?FILE_HANDLE2, DataSize}),
      ReadFunOpt = make_opt_fun(read_fun, {ok, ?FILE_HANDLE2, Data}),
      RtransferOpts = [ReadFunOpt, WriteFunOpt | ?DEFAULT_RTRANSFER_OPTS],
      RtransferOpts2 =
          change_rtransfer_opt({open_fun, {error, test_error}}, RtransferOpts),
  
      %% when
      prepare_rtransfer(
          {Worker1, [[get_binding(Worker1) | RtransferOpts2]]},
          {Worker2, [[get_binding(Worker2) | RtransferOpts2]]},
          ?TEST_FILE_UUID, ?TEST_OFFSET, DataSize,
          notify_fun(), on_complete_fun(self())
      ),
  
      %% then
      ?assertReceivedMatch({on_complete, {error,{storage,_}}}, ?TIMEOUT).
  