anchor.diff:  
   all() -> ?ALL([
       change_bridge_restarts,
  +    multiple_updates_test,
       no_space_update_test,
       space_update_through_support_test,
       space_update_through_users_test,
  
positive.code:     receive
          {push, Messages} ->
              get_messages(Retries - 1, [json_utils:decode(Messages) | Acc])
      after 500 -> Acc
      end.
negative.code:     % then
      verify_messages(Context, [
          user_expectation(<<"u1">>, <<"updated">>, [], [])
      ], []),
      ok.
  
  multiple_updates_test(Config) ->
      % given
      [Node | _] = ?config(oz_worker_nodes, Config),
      P1 = create_provider(Node, <<"p1">>, [<<"s1">>]),
      create_user(Node, <<"u1">>, [], []),
      call_worker(Node, {add_connection, P1, self()}),
  
      % when
      Context = init_messages(Node, P1, [<<"u1">>]),
      update_document(Node, onedata_user, <<"u1">>, #{name => <<"updated1">>}),
      update_document(Node, onedata_user, <<"u1">>, #{name => <<"updated2">>}),
      update_document(Node, onedata_user, <<"u1">>, #{name => <<"updated3">>}),
      update_document(Node, onedata_user, <<"u1">>, #{name => <<"updated4">>}),
  
      % then
      verify_messages(Context, [
          user_expectation(<<"u1">>, <<"updated4">>, [], [])
      ], []),
      ok.
  
  