anchor.diff:  
               amoc_throttle:start(?NODE_CREATION_THROTTLING, NodeCreationRate),
               amoc_throttle:start(?PUBLICATION_THROTTLING, PublicationRate),
  +            start_coordinator(Settings),
               {ok, Settings};
           Error -> Error
       end.
  
positive.code:     user_loop(Settings, Client, #{}).
  
  create_new_node(Client, Settings) ->
      Coordinator = get_coordinator_pid(),
      amoc_throttle:send_and_wait(?NODE_CREATION_THROTTLING, create_node),
      create_pubsub_node(Client, Settings),
      Coordinator ! {new_client, self(), Client}.
  
  user_loop(Settings, Client, Requests) ->
      IqTimeout = get_parameter(iq_timeout, Settings),
  
negative.code: -spec start(amoc_scenario:user_id(), amoc_scenario:state()) -> any().
  start(Id, Settings) ->
      Client = connect_amoc_user(Id, Settings),
      start_user(Client, Settings).
  
  init_metrics() ->
      Counters = [message,
  