anchor.diff:      ets_state:delete_collection(?STATE_ID, guid_to_provider),
       ets_state:delete_collection(?STATE_ID, sub_to_guid),
       ets_state:delete(?STATE_ID, self(), session_id),
  -    ets_state:delete(?STATE_ID, self(), proxy_via).+    ets_state:delete(?STATE_ID, self(), proxy_via).
  +
  +%% @private
  +-spec call_manager(pid(), term()) -> term().
  +call_manager(Manager, Request) ->
  +    gen_server2:call(Manager, Request, ?LOCAL_CALL_TIMEOUT).
positive.code: %% @private
  %% @doc
  %% Handles flush request locally (in caller process) or delegates it to manager
  %% if manager initialization is not finished.
  %% @end
  %%--------------------------------------------------------------------
  -spec handle_flush(FlushRequest :: #flush_events{}, Manager :: pid(),
  
negative.code:         {{ok, Stm}, _} ->
              ok = event_stream:send(Stm, Evt);
          {_, true} ->
              case ets_state:get(?STATE_ID, Manager, ?INITIALIZATION_STATUS_KEY) of
                  {ok, ?INITIALIZATION_STATUS_FINISHED_VALUE} -> handle_event(Evt, Manager, false);
                  _ -> call_manager(Manager, Evt)
              end,
              ok;
          _ ->
  