anchor.diff:      call_worker(Node, {add_connection, P1, self()}),
   
       % when
  -    Context = init_messages(Node, P1, [<<"u1">>]),
  +    Context1 = init_messages(Node, P1, [<<"u1">>]),
  +    Context = flush_messages(Context1, group_expectation(<<"g1">>, <<"g1">>)),
       update_document(Node, user_group, <<"g1">>, #{name => <<"updated">>}),
   
       % then
  
positive.code:     call_worker(Node, {add_connection, P1, self()}),
  
      % when
      Context = init_messages(Node, P1, [UniqueID]),
      update_document(Node, onedata_user, UniqueID, #{name => <<"updated1">>}),
      Rev1 = get_rev(Node, onedata_user, UniqueID),
      update_document(Node, onedata_user, UniqueID, #{name => <<"updated2">>}),
  
negative.code: 
  %%%===================================================================
  %%% Internal functions
  %%%===================================================================
  
  empty_cache(Node) ->
      update_document(Node, subscriptions_state, ?SUBSCRIPTIONS_STATE_KEY, #{
          cache => gb_trees:empty()
      }).
  
  call_worker(Node, Req) ->
      rpc:call(Node, worker_proxy, call, [?SUBSCRIPTIONS_WORKER_NAME, Req]).
  
  %%%===================================================================
  %%% Internal: datastore setup
  %%%===================================================================
  
  create_group(Node, Name, Users, Spaces) ->
  