anchor.diff:      fuse_test_utils:close(Sock, FileGuid, HandleId),
   
       ?assertEqual(ok, lfm_proxy:unlink(Worker1, <<"0">>, {guid, FileGuid})),
  -    ?assertEqual(ok, receive_file_removed_event()),
  +    receive_events_and_check(file_removed, FileGuid),
   
       ?assertEqual(ok, ssl:send(Sock,
           fuse_test_utils:generate_subscription_cancellation_message(0, get_seq(Config, <<"user1">>), -Seq1))),
  
positive.code:         rpc:call(Worker1, subscription_manager, get_subscribers, [SubscriptionRoutingKey, undefined]), 10),
  
      rpc:call(Worker1, fslogic_event_emitter, emit_file_attr_changed, [file_ctx:new_by_guid(SpaceGuid), []]),
      ?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))),
  
negative.code:     ok.
  
  subscribe_on_user_root_test(Config) ->
      subscribe_on_user_root_test_base(Config, <<"user1">>, file_attr_changed).
  
  subscribe_on_user_root_filter_test(Config) ->
      subscribe_on_user_root_test_base(Config, <<"user2">>, {not_received, file_attr_changed}).
  
  subscribe_on_user_root_test_base(Config, User, ExpectedAns) ->
      [Worker1 | _] = ?config(op_worker_nodes, Config),
  