anchor.diff:      ?assertMatch(ExpectedResponses, replicate_blocks(
           Worker1a, SessId(Worker1a, User1), FileCtx, FollowingBlocks
       )),
  -    ?assertMatch([ok, ok], async_replicate_blocks_end([Promise1, Promise2])),
  +    ?assertMatch([ok, ok, ok, ok],
  +        async_replicate_blocks_end([Promise1 | Promises2])
  +    ),
   
       FetchRequests = lists:sum(meck_get_num_calls(
           Workers1, rtransfer_config, fetch, '_')
  
positive.code:         Worker1a, SessId(Worker1a, User1), FileCtx, [InitialBlock1]
      ),
      timer:sleep(timer:seconds(5)),
      [Promise2] = async_replicate_blocks_start(
          Worker1a, SessId(Worker1a, User1), FileCtx, [InitialBlock2]
      ),
      timer:sleep(timer:seconds(5)),
  
  
negative.code:     ),
  
      Config2;
  init_per_testcase(rtransfer_fetch_test, Config) ->
      Config2 = init_per_testcase(?DEFAULT_CASE(rtransfer_fetch_test), Config),
  
      [Node | _ ] = Nodes = ?config(op_worker_nodes, Config),
      {ok, HoleSize} = rpc:call(Node, application, get_env, [
          ?APP_NAME, rtransfer_min_hole_size
      ]),
      rpc:multicall(Nodes, application, set_env, [
          ?APP_NAME, rtransfer_min_hole_size, 6
      ]),
  
      [{default_min_hole_size, HoleSize} | Config2];
  init_per_testcase(_Case, Config) ->
      ct:timetrap({minutes, 60}),
      lfm_proxy:init(Config).
  