anchor.diff:  
       ?assertEqual(ok, lfm_proxy:unlink(Worker1, <<"0">>, {guid, FileGuid})),
       ?assertEqual(ok, receive_file_removed_event()),
  +
       ?assertEqual(ok, ssl:send(Sock,
           fuse_test_utils:generate_subscription_cancellation_message(0, get_seq(Config, <<"user1">>), -Seq1))),
  +    ?assertMatch({ok, []},
  +        rpc:call(Worker1, subscription_manager, get_subscribers, [SubscriptionRoutingKey, undefined]), 10),
       ?assertEqual(ok, ssl:close(Sock)),
       ok.
   
  
positive.code: all() ->
      ?ALL([
          subscribe_on_dir_test,
          subscribe_on_replication_info_test,
          subscribe_on_user_root_test,
          subscribe_on_user_root_filter_test,
          subscribe_on_new_space_test,
          subscribe_on_new_space_filter_test,
          events_on_conflicts_test
      ]).
  
  -define(CONFLICTING_FILE_NAME, <<"abc">>).
  
negative.code: 
      rpc:call(Worker1, file_meta, make_space_exist, [<<"space_id", SpaceNum/binary>>]),
      ?assertEqual(ExpectedAns, receive_file_attr_changed_event()),
  
      ?assertEqual(ok, ssl:send(Sock,
          fuse_test_utils:generate_subscription_cancellation_message(0, get_seq(Config, User), -Seq1))),
      ?assertMatch({ok, []},
          rpc:call(Worker1, subscription_manager, get_subscribers, [SubscriptionRoutingKey, undefined]), 10),
      ?assertEqual(ok, ssl:close(Sock)),
      ok.
  
  