anchor.diff:  
   -include("workers/datastore/models/session.hrl").
   -include("proto_internal/oneclient/common_messages.hrl").
  --include("workers/session/event_manager/read_event.hrl").
  --include("workers/session/event_manager/write_event.hrl").
  +-include("proto_internal/oneclient/event_messages.hrl").
   -include_lib("ctool/include/logging.hrl").
   -include_lib("ctool/include/test/test_utils.hrl").
   -include_lib("ctool/include/test/assertions.hrl").
   
   %% export for ct
  --export([all/0, init_per_suite/1, end_per_suite/1]).
  +-export([all/0, init_per_suite/1, end_per_suite/1, init_per_testcase/2,
  +    end_per_testcase/2]).
   
   %% tests
   -export([
  -    event_stream_test/1
  +    event_stream_test/1,
  +    event_manager_test/1
   ]).
   
   all() -> [
  -    event_stream_test
  +    event_stream_test,
  +    event_manager_test
   ].
   
   -define(TIMEOUT, timer:seconds(5)).
  
positive.code: 
  %% Test single subscription and execution of event handler.
  event_stream_test(Config) ->
      [Worker1, Worker2] = ?config(op_worker_nodes, Config),
      Self = self(),
      SessId1 = <<"session_id_1">>,
      SessId2 = <<"session_id_2">>,
  
negative.code:     session_setup(Worker1, SessId1, Cred1, Self),
  
      {ok, SubId} = subscribe(Worker2,
          all,
          fun(#write_event{}) -> true; (_) -> false end,
          fun(Meta) -> Meta >= 6 end,
          [fun(Evts) -> Self ! {handler, Evts} end]
  