anchor.diff:      call_worker(Node, {add_connection, P1, self()}),
   
       % when
  -    Context = init_messages(Node, P1, [UniqueID]),
  +    Context1 = init_messages(Node, P1, [UniqueID]),
  +    Context = flush_messages(Context1, user_expectation(UniqueID, UniqueID, [], [])),
       update_document(Node, onedata_user, UniqueID, #{name => <<"updated1">>}),
       Rev1 = get_rev(Node, onedata_user, UniqueID),
       update_document(Node, onedata_user, UniqueID, #{name => <<"updated2">>}),
  
positive.code:     os:cmd("openssl req -new -batch -key " ++ KeyFile ++ " -out " ++ CSRFile),
      {KeyFile, CSRFile, CertFile}.
  
  call_worker(Node, Req) ->
      rpc:call(Node, worker_proxy, call, [subscriptions_worker, Req]).
  
  
  %%%===================================================================
  %%% Internal: Message expectations
  
negative.code: -author("Michal Zmuda").
  
  -include("registered_names.hrl").
  -include("subscriptions/subscriptions.hrl").
  -include("datastore/oz_datastore_models_def.hrl").
  -include_lib("ctool/include/test/test_utils.hrl").
  -include_lib("ctool/include/logging.hrl").
  