anchor.diff:  %% tests
   -export([
       event_stream_test/1,
  +    event_stream_periodic_emission_test/1,
       event_stream_crash_test/1,
       event_manager_test/1
   ]).
   
   all() -> [
       event_stream_test,
  +    event_stream_periodic_emission_test,
       event_stream_crash_test,
       event_manager_test
   ].
  
positive.code:     Handlers :: [event_stream:event_handler()]) ->
      {ok, SubId :: event_manager:subscription_id()}.
  subscribe(Worker, Producer, AdmRule, EmRule, Handlers) ->
      Sub = #write_event_subscription{
          producer = Producer,
          event_stream = ?WRITE_EVENT_STREAM#event_stream{
              metadata = 0,
              admission_rule = AdmRule,
              emission_rule = EmRule,
              handlers = Handlers
          }
      },
  
negative.code:     test_utils:mock_unload(Worker, [communicator, logger]),
      proplists:delete(session_id, Config);
  
  end_per_testcase(Case, Config) when
      Case =:= event_stream_periodic_emission_test;
      Case =:= event_manager_test ->
      [Worker | _] = ?config(op_worker_nodes, Config),
      SessId = ?config(session_id, Config),
      session_teardown(Worker, SessId),
  