anchor.diff:  %% after delay.
   %% @end
   %%--------------------------------------------------------------------
  --spec ensure_sent(Msg ::term(), SessId :: session:id()) -> ok.
  +-spec ensure_sent(Msg :: term(), SessId :: session:id()) -> ok.
   ensure_sent(Msg, SessId) ->
       case communicator:send(Msg, SessId) of
           ok ->
  
positive.code:     ?debug("Initializing sequencer manager for session ~p", [SessId]),
      process_flag(trap_exit, true),
      {ok, SessId} = session:update(SessId, #{sequencer_manager => self()}),
      send_message_stream_reset(SessId),
      {ok, #state{sequencer_manager_sup = SeqManSup, session_id = SessId}, 0}.
  
  %%--------------------------------------------------------------------
  
negative.code: handle_info({'EXIT', SeqManSup, shutdown}, #state{sequencer_manager_sup = SeqManSup} = State) ->
      {stop, normal, State};
  
  handle_info(timeout, #state{sequencer_manager_sup = SeqManSup, session_id = SessId} = State) ->
      send_message_stream_reset(SessId),
      {ok, SeqInStmSup} = sequencer_manager_sup:get_sequencer_stream_sup(
          SeqManSup, sequencer_in_stream_sup
      ),
  