anchor.diff:                                              -> ?assert(false)
                                             end).
   
  -%% @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.
  -%% @end
   test_event_subscription(Config) ->
     nodes_manager:check_start_assertions(Config),
     NodesUp = ?config(nodes, Config),
  
positive.code:   timer:sleep(1000),
    count_answers(8),
  
    repeat(200, SendWriteEvents),
    timer:sleep(3000),
    {Count, SetOfPids} = count_answers(4*200),
    ?assertEqual(0, Count),
    ?assertEqual(6, sets:size(SetOfPids)),
  
    SendWriteEvents(),
    {Count2, SetOfPids2} = count_answers(4),
    ?assertEqual(0, Count2),
    ?assertEqual(4, sets:size(SetOfPids2)).
  
  
  %% ====================================================================
  
negative.code:   WriteEvent2 = #write_event{user_id = "1235", ans_pid = self()},
    WriteEvent3 = #write_event{user_id = "1334", ans_pid = self()},
    WriteEvent4 = #write_event{user_id = "1335", ans_pid = self()},
    WriteEvent5 = #write_event{user_id = "1236", ans_pid = self()},
    WriteEvents = [WriteEvent1, WriteEvent2, WriteEvent3, WriteEvent4],
    SendWriteEvent = fun (Event) -> send_event(Event, CCM) end,
  
  