anchor.diff:      % 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.
   
  
positive.code:     receive
          {push, Messages} ->
              get_messages(Retries - 1, [json_utils:decode(Messages) | Acc])
      after 500 -> Acc
      end.
negative.code: 
  all() -> ?ALL([
      change_bridge_restarts,
      multiple_updates_test,
      no_space_update_test,
      space_update_through_support_test,
      space_update_through_users_test,
  