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(), on_complete_fun(self())),
  -    cancel_fetching(Worker1, Ref1),
  +    Ref = prepare_rtransfer({Worker1, RtransferOpts1}, {Worker2, RtransferOpts2},
  +        ?TEST_FILE_UUID, ?TEST_OFFSET, DataSize,
  +        notify_fun(), on_complete_fun(self())
  +    ),
  +    cancel_fetching(Worker1, Ref),
   
       timer:sleep(?TIMEOUT),
       %% then
  
positive.code:     remote_apply(Node, rtransfer, fetch, [Ref, NotifyFun, OnCompleteFun]).
  
  cancel_fetching(Node, Ref) ->
      remote_apply(Node, rtransfer, cancel, [Ref]).
negative.code:     RtransferOpts2 = [ReadFunOpt, WriteFunOpt, get_binding(Worker2) | ?DEFAULT_RTRANSFER_OPTS],
  
      %% when
      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),
  