anchor.diff:      end,
       {noreply, State};
   
  -handle_cast(#event{} = Evt, #state{session_id = SessId, event_streams = EvtStms, entry_to_provider_map = ProvMap} = State) ->
  +do_handle_cast(#event{} = Evt, #state{session_id = SessId, event_streams = EvtStms, entry_to_provider_map = ProvMap} = State) ->
       ?debug("Handling event ~p in session ~p", [Evt, SessId]),
       HandleLocally =
           fun
  
positive.code: %%--------------------------------------------------------------------
  %% @private
  %% @doc
  %% Handles cast messages.
  %% @end
  %%--------------------------------------------------------------------
  -spec handle_cast(Request :: term(), State :: #state{}) ->
      {noreply, NewState :: #state{}} |
      {noreply, NewState :: #state{}, timeout() | hibernate} |
      {stop, Reason :: term(), NewState :: #state{}}.
  handle_cast({register_stream, SubId, EvtStm}, #state{event_streams = EvtStms} = State) ->
      {noreply, State#state{event_streams = maps:put(SubId, EvtStm, EvtStms)}};
  
  handle_cast({unregister_stream, SubId}, #state{event_streams = EvtStms} = State) ->
      {noreply, State#state{event_streams = maps:remove(SubId, EvtStms)}};
  
  handle_cast({flush_stream, SubId, Notify}, #state{event_streams = Stms,
      session_id = SessId} = State) ->
      case maps:find(SubId, Stms) of
          {ok, Stm} ->
  
negative.code: 
      handle_or_reroute(#events{events = [Evt]}, request_to_file_entry_or_provider(Evt), SessId, HandleLocally, ProvMap);
  
  do_handle_cast(#flush_events{provider_id = ProviderId, subscription_id = SubId, notify = NotifyFun} = Evt,
      #state{session_id = SessId, event_streams = EvtStms, entry_to_provider_map = ProvMap} = State) ->
      ?debug("Handling event ~p in session ~p", [Evt, SessId]),
      HandleLocally =
  