anchor.diff:      string_to_integer(UserIdString)
     end,
   
  -  EventHandlerDispMapFun = fun (#write_event{user_id = UserId}) ->
  +  EventHandlerDispMapFun = fun(#write_event{user_id = UserId}) ->
       UserIdInt = string_to_integer(UserId),
       UserIdInt div 100
     end,
  
positive.code: -export([all/0, init_per_testcase/2, end_per_testcase/2]).
  all() -> [test_event_subscription, test_event_aggregation].
  
  %% @doc This is distributed test of dao_vfs:find_files.
  %% It consists of series of dao_vfs:find_files with various file_criteria and comparing result to expected values.
  %% Before testing it clears documents that may affect test and after testing it clears created documents.
  
negative.code:     error ->
        throw(badarg);
      _ -> SomeInteger
    end.
  
  assert_nothing_received() ->
    receive
      _ -> ?assert(false)
    after 1000
      -> ok
    end.
  
  send_event(Event, Node) ->
    gen_server:call({?Dispatcher_Name, Node}, {cluster_rengine, 1, {event_arrived, Event}}).
  